(b []byte)
| 369 | } |
| 370 | |
| 371 | func (r *websocketReader) addCBuf(b []byte) { |
| 372 | if r.dc == nil { |
| 373 | r.dc = &wsDecompressor{} |
| 374 | } |
| 375 | // Add a copy of the incoming buffer to the list of compressed buffers. |
| 376 | r.dc.addBuf(append([]byte(nil), b...)) |
| 377 | } |
| 378 | |
| 379 | func (r *websocketReader) drainPending(p []byte) int { |
| 380 | var n int |