(stream, state, chunk, addToFront)
| 6364 | } |
| 6365 | |
| 6366 | function addChunk(stream, state, chunk, addToFront) { |
| 6367 | if (state.flowing && state.length === 0 && !state.sync) { |
| 6368 | stream.emit('data', chunk); |
| 6369 | stream.read(0); |
| 6370 | } else { |
| 6371 | // update the buffer info. |
| 6372 | state.length += state.objectMode ? 1 : chunk.length; |
| 6373 | if (addToFront) state.buffer.unshift(chunk);else state.buffer.push(chunk); |
| 6374 | |
| 6375 | if (state.needReadable) emitReadable(stream); |
| 6376 | } |
| 6377 | maybeReadMore(stream, state); |
| 6378 | } |
| 6379 | |
| 6380 | function chunkInvalid(state, chunk) { |
| 6381 | var er; |
no test coverage detected
searching dependent graphs…