Lines Matching refs:chunk
178 async write(chunk) {
179 if (streamWritable.writableNeedDrain || !streamWritable.write(chunk)) {
264 (data) => writer.write(data.chunk)),
271 write(chunk, encoding, callback) {
272 if (typeof chunk === 'string' && decodeStrings && !objectMode) {
276 chunk = encoder.encode(chunk);
278 chunk = Buffer.from(chunk, encoding);
279 chunk = new Uint8Array(
280 TypedArrayPrototypeGetBuffer(chunk),
281 TypedArrayPrototypeGetByteOffset(chunk),
282 TypedArrayPrototypeGetByteLength(chunk),
299 writer.write(chunk),
431 function onData(chunk) {
433 if (Buffer.isBuffer(chunk) && !objectMode)
434 chunk = new Uint8Array(chunk);
435 controller.enqueue(chunk);
512 (chunk) => {
513 if (chunk.done) {
517 readable.push(chunk.value);
690 (data) => writer.write(data.chunk)),
697 write(chunk, encoding, callback) {
698 if (typeof chunk === 'string' && decodeStrings && !objectMode) {
702 chunk = encoder.encode(chunk);
704 chunk = Buffer.from(chunk, encoding);
705 chunk = new Uint8Array(
706 TypedArrayPrototypeGetBuffer(chunk),
707 TypedArrayPrototypeGetByteOffset(chunk),
708 TypedArrayPrototypeGetByteLength(chunk),
725 writer.write(chunk),
757 (chunk) => {
758 if (chunk.done) {
761 duplex.push(chunk.value);
867 function doWrite(chunk, controller) {
873 ret = streamBase.writeBuffer(req, chunk);
875 req.buffer = chunk;
890 write(chunk, controller) {
894 () => doWrite(chunk, controller),
896 doWrite(chunk, controller);