Home
last modified time | relevance | path

Searched refs:objectMode (Results 1 – 25 of 107) sorted by relevance

12345

/third_party/node/test/parallel/
Dtest-stream2-objects.js30 const stream = new Writable({ objectMode: true }); property
44 const r = new Readable({ objectMode: true }); property
89 const r = new Readable({ objectMode: true }); property
106 const r = new Readable({ objectMode: true }); property
126 objectMode: true property
143 objectMode: true property
158 objectMode: true property
176 objectMode: true property
207 objectMode: true property
218 const w = new Writable({ objectMode: true }); property
[all …]
Dtest-stream-pipe-flow.js10 objectMode: true, property
21 objectMode: true, property
34 objectMode: true, property
42 .pipe(new PassThrough({ objectMode: true, highWaterMark: 2 })) property
43 .pipe(new PassThrough({ objectMode: true, highWaterMark: 2 })); property
50 objectMode: true, property
75 .pipe(new PassThrough({ objectMode: true, highWaterMark: 2 })); property
Dtest-stream-readable-async-iterators.js72 const readable = new Readable({ objectMode: true, read() {} }); property
88 objectMode: true, property
117 objectMode: true, property
158 objectMode: true, property
217 objectMode: true, property
237 objectMode: true, property
256 objectMode: true, property
288 objectMode: true, property
311 objectMode: true, property
356 objectMode: true, property
[all …]
Dtest-stream-transform-split-objectmode.js30 assert(parser._readableState.objectMode);
31 assert(!parser._writableState.objectMode);
58 assert(!serializer._readableState.objectMode);
59 assert(serializer._writableState.objectMode);
Dtest-stream-readable-object-multi-push-async.js12 objectMode: true, property
62 objectMode: true, property
108 objectMode: true, property
149 objectMode: true, property
169 objectMode: true, property
Dtest-stream-transform-objectmode-falsey-value.js29 const src = new PassThrough({ objectMode: true }); property
30 const tx = new PassThrough({ objectMode: true }); property
31 const dest = new PassThrough({ objectMode: true }); property
Dtest-stream-duplex.js27 const stream = new Duplex({ objectMode: true }); property
30 assert(stream._readableState.objectMode);
31 assert(stream._writableState.objectMode);
Dtest-stream-objectmode-undefined.js8 objectMode: true, property
22 objectMode: true, property
33 objectMode: true, property
Dtest-stream-writable-null.js18 const m = new MyWritable({ objectMode: true }); property
38 const m = new MyWritable({ objectMode: true }); property
43 const m = new MyWritable({ objectMode: true }).on('error', (e) => { property
/third_party/node/deps/npm/node_modules/sorted-union-stream/
Dtest.js6 var a = new Readable({objectMode: true}) property
7 var b = new Readable({objectMode: true}) property
38 var a = new Readable({objectMode: true}) property
39 var b = new Readable({objectMode: true}) property
70 var a = new Readable({objectMode: true}) property
71 var b = new Readable({objectMode: true}) property
102 var a = new Readable({objectMode: true}) property
103 var b = new Readable({objectMode: true}) property
137 var a = new Readable({objectMode: true}) property
138 var b = new Readable({objectMode: true}) property
/third_party/node/deps/npm/node_modules/get-stream/
Dbuffer-stream.js10 let objectMode = false; variable
13 objectMode = !(encoding || buffer);
24 const stream = new PassThrough({objectMode}); field
33 if (objectMode) {
/third_party/node/deps/npm/node_modules/got/node_modules/get-stream/
Dbuffer-stream.js10 let objectMode = false; variable
13 objectMode = !(encoding || buffer);
24 const stream = new PassThrough({objectMode}); field
33 if (objectMode) {
/third_party/node/deps/npm/node_modules/execa/node_modules/get-stream/
Dbuffer-stream.js10 let objectMode = false; variable
13 objectMode = !(encoding || buffer);
24 const stream = new PassThrough({objectMode}); field
33 if (objectMode) {
/third_party/node/deps/npm/node_modules/sorted-union-stream/node_modules/readable-stream/lib/
D_stream_writable.js59 var defaultHwm = options.objectMode ? 16 : 16 * 1024;
64 this.objectMode = !!options.objectMode;
67 this.objectMode = this.objectMode || !!options.writableObjectMode;
179 !state.objectMode) {
239 if (!state.objectMode &&
254 var len = state.objectMode ? 1 : chunk.length;
383 var len = state.objectMode ? 1 : chunk.length;
D_stream_readable.js73 var defaultHwm = options.objectMode ? 16 : 16 * 1024;
103 this.objectMode = !!options.objectMode;
106 this.objectMode = this.objectMode || !!options.readableObjectMode;
154 if (util.isString(chunk) && !state.objectMode) {
179 } else if (state.objectMode || chunk && chunk.length > 0) {
199 state.length += state.objectMode ? 1 : chunk.length;
261 if (state.objectMode)
415 !state.objectMode) {
427 state.length += state.objectMode ? 1 : chunk.length;
809 if (!chunk || !state.objectMode && !chunk.length)
[all …]
/third_party/node/lib/internal/streams/
Dstate.js15 function getDefaultHighWaterMark(objectMode) { argument
16 return objectMode ? 16 : 16 * 1024;
30 return getDefaultHighWaterMark(state.objectMode);
/third_party/node/deps/npm/node_modules/are-we-there-yet/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/stream-iterate/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/parallel-transform/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/from2/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/fs-write-stream-atomic/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/duplexify/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/concat-stream/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/flush-write-stream/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]
/third_party/node/deps/npm/node_modules/through2/node_modules/readable-stream/lib/
D_stream_readable.js115 this.objectMode = !!options.objectMode;
117 if (isDuplex) this.objectMode = this.objectMode || !!options.readableObjectMode;
123 var defaultHwm = this.objectMode ? 16 : 16 * 1024;
232 if (!state.objectMode) {
263 } else if (state.objectMode || chunk && chunk.length > 0) {
264 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
276 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
295 state.length += state.objectMode ? 1 : chunk.length;
305 … (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
357 if (state.objectMode) return 1;
[all …]

12345