| /third_party/node/test/fixtures/wpt/streams/ |
| D | queuing-strategies.any.js | 18 new QueuingStrategy({ highWaterMark: 4 }); property
22 const highWaterMark = 1; constant
24 get highWaterMark() { return highWaterMark; } getter
28 get highWaterMark() { throw error; } getter
39 assert_equals((new QueuingStrategy(highWaterMarkObjectGetter)).highWaterMark, highWaterMark);
44 const strategy = new QueuingStrategy({ highWaterMark: input }); property
45 assert_equals(strategy.highWaterMark, output, `${input} gets set correctly`);
50 const size1 = (new QueuingStrategy({ highWaterMark: 5 })).size; property
51 const size2 = (new QueuingStrategy({ highWaterMark: 10 })).size; property
57 const size = (new QueuingStrategy({ highWaterMark: 5 })).size; property
[all …]
|
| /third_party/node/lib/internal/webstreams/ |
| D | queuingstrategies.js | 80 if (init.highWaterMark === undefined)
86 highWaterMark: +init.highWaterMark,
94 get highWaterMark() { getter in ByteLengthQueuingStrategy
97 return this[kState].highWaterMark;
111 highWaterMark: this.highWaterMark, property
117 highWaterMark: kEnumerableProperty, property
135 if (init.highWaterMark === undefined)
141 highWaterMark: +init.highWaterMark,
149 get highWaterMark() { getter in CountQueuingStrategy
152 return this[kState].highWaterMark;
[all …]
|
| D | adapters.js | 124 const highWaterMark = streamWritable.writableHighWaterMark;
127 new CountQueuingStrategy({ highWaterMark }) : field
128 { highWaterMark };
225 highWaterMark,
238 highWaterMark, property
407 const highWaterMark = streamReadable.readableHighWaterMark;
417 return new CountQueuingStrategy({ highWaterMark }); field
424 return { highWaterMark };
490 highWaterMark,
505 highWaterMark, property
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-stream-transform-split-highwatermark.js | 11 assert.strictEqual(t._readableState.highWaterMark, expectedReadableHwm);
12 assert.strictEqual(t._writableState.highWaterMark, expectedWritableHwm);
25 highWaterMark: 555, property
29 highWaterMark: 555, property
33 highWaterMark: 555, property
42 testTransform(666, DEFAULT, { highWaterMark: v, readableHighWaterMark: 666 }); property
43 testTransform(DEFAULT, 777, { highWaterMark: v, writableHighWaterMark: 777 }); property
70 assert.strictEqual(r._readableState.highWaterMark, DEFAULT);
72 assert.strictEqual(w._writableState.highWaterMark, DEFAULT);
|
| D | test-streams-highwatermark.js | 17 const readable = stream.Readable({ highWaterMark: ovfl }); property
18 assert.strictEqual(readable._readableState.highWaterMark, ovfl);
20 const writable = stream.Writable({ highWaterMark: ovfl }); property
21 assert.strictEqual(writable._writableState.highWaterMark, ovfl);
26 type({ highWaterMark: invalidHwm }); property
42 const readable = stream.Readable({ highWaterMark: 0 }); property
55 const readable = stream.Readable({ highWaterMark: 0 }); property
66 highWaterMark: 0, property
70 assert.strictEqual(readable._readableState.highWaterMark, Number(size));
|
| D | test-https-hwm.js | 15 function loadCallback(highWaterMark) { argument
17 assert.strictEqual(highWaterMark, res.readableHighWaterMark);
46 highWaterMark: 128000, property
55 highWaterMark: 0, property
64 highWaterMark: undefined, property
|
| D | test-stream2-readable-wrap.js | 28 function runTest(highWaterMark, objectMode, produce) { argument
31 const r = new Readable({ highWaterMark, objectMode }); property
73 const w = new Writable({ highWaterMark: highWaterMark * 2, property
|
| D | test-stream-transform-split-objectmode.js | 35 parser._readableState.highWaterMark);
37 parser._writableState.highWaterMark);
63 parser._readableState.highWaterMark);
65 parser._writableState.highWaterMark);
|
| D | test-stream-pipe-flow.js | 20 highWaterMark: 0, property
42 .pipe(new PassThrough({ objectMode: true, highWaterMark: 2 })) property
43 .pipe(new PassThrough({ objectMode: true, highWaterMark: 2 })); property
75 .pipe(new PassThrough({ objectMode: true, highWaterMark: 2 })); property
|
| D | test-readline-async-iterators-backpressure.js | 21 const highWaterMark = it.stream.readableHighWaterMark; constant
25 assert(TOTAL_LINES > highWaterMark);
34 const expectedPaused = TOTAL_LINES - iterations > highWaterMark;
|
| D | test-http-server-options-highwatermark.js | 25 highWaterMark: getDefaultHighWaterMark() * 2, property
27 assert.strictEqual(req._readableState.highWaterMark, getDefaultHighWaterMark() * 2);
39 assert.strictEqual(req._readableState.highWaterMark, getDefaultHighWaterMark());
|
| D | test-tls-connect-hwm-option.js | 28 highWaterMark: 128000, property
38 highWaterMark: undefined, property
48 highWaterMark: 0, property
|
| D | test-whatwg-writablestream.js | 69 ['a', {}].forEach((highWaterMark) => {
70 assert.throws(() => new WritableStream({}, { highWaterMark }), { field
91 new CountQueuingStrategy({ highWaterMark: 1 })); property
126 new CountQueuingStrategy({ highWaterMark: 1 })); property
144 sink, { highWaterMark: 1 } property
|
| D | test-stream-readable-strategy-option.js | 22 strategy: new ByteLengthQueuingStrategy({ highWaterMark: 1 }), property
44 strategy: new CountQueuingStrategy({ highWaterMark: 1 }), property
64 new CountQueuingStrategy({ highWaterMark: desireSizeExpected }) property
|
| D | test-stream-readable-event.js | 32 highWaterMark: 3 property
52 highWaterMark: 3 property
71 highWaterMark: 30 property
|
| /third_party/node/test/fixtures/wpt/streams/transform-streams/ |
| D | strategies.any.js | 11 const ts = new TransformStream({}, { highWaterMark: 17 }); property
16 const ts = recordingTransformStream({}, undefined, { highWaterMark: 9 }); property
56 highWaterMark: Infinity property
89 assert_throws_js(RangeError, () => new TransformStream(undefined, { highWaterMark: -1 }), property
91 …assert_throws_js(RangeError, () => new TransformStream(undefined, undefined, { highWaterMark: -1 }… property
93 assert_throws_js(RangeError, () => new TransformStream(undefined, { highWaterMark: NaN }), property
95 …assert_throws_js(RangeError, () => new TransformStream(undefined, undefined, { highWaterMark: NaN … property
106 const ts = new TransformStream(undefined, { highWaterMark: objectThatConvertsTo42 }); property
116 }, undefined, { highWaterMark: objectThatConvertsTo42 }); property
122 highWaterMark: 1 property
[all …]
|
| D | reentrant-strategies.any.js | 33 highWaterMark: Infinity property
55 highWaterMark: Infinity property
76 highWaterMark: Infinity property
94 highWaterMark: 1 property
109 highWaterMark: Infinity property
134 highWaterMark: 1 property
174 highWaterMark: 0 property
212 highWaterMark: Infinity property
247 highWaterMark: Infinity property
279 highWaterMark: 1 property
[all …]
|
| D | backpressure.any.js | 20 const ts = recordingTransformStream({}, undefined, { highWaterMark: 1 }); property
38 }, undefined, { highWaterMark: 1 }); property
51 const ts = new TransformStream({}, undefined, { highWaterMark: 1 }); property
80 const ts = new TransformStream(undefined, undefined, { highWaterMark: 0 }); property
98 }, undefined, { highWaterMark: 1 }); property
113 }, undefined, new CountQueuingStrategy({ highWaterMark: Infinity })); property
137 const ts = new TransformStream({}, undefined, { highWaterMark: 0 }); property
145 const ts = new TransformStream({}, undefined, { highWaterMark: 1 }); property
153 const ts = new TransformStream({}, undefined, { highWaterMark: 1 }); property
|
| /third_party/node/test/fixtures/wpt/streams/readable-streams/ |
| D | bad-strategies.any.js | 13 highWaterMark: 5 property
36 highWaterMark: 5 property
62 highWaterMark: 5 property
85 highWaterMark: 5 property
104 get highWaterMark() { getter
114 for (const highWaterMark of [-1, -Infinity, NaN, 'foo', {}]) {
120 highWaterMark field
122 }, 'construction should throw a RangeError for ' + highWaterMark);
148 highWaterMark: 5 property
|
| /third_party/node/test/fixtures/wpt/streams/writable-streams/ |
| D | bad-strategies.any.js | 13 highWaterMark: 5 property
30 get highWaterMark() { getter
39 for (const highWaterMark of [-1, -Infinity, NaN, 'foo', {}]) {
45 highWaterMark field
47 }, `construction should throw a RangeError for ${highWaterMark}`);
56 highWaterMark: 5 property
75 highWaterMark: 5 property
93 highWaterMark: NaN property
|
| /third_party/node/deps/undici/src/lib/api/ |
| D | api-request.js | 19 …const { signal, method, opaque, body, onInfo, responseHeaders, throwOnError, highWaterMark } = opts
26 if (highWaterMark && (typeof highWaterMark !== 'number' || highWaterMark < 0)) {
60 this.highWaterMark = highWaterMark
81 const { callback, opaque, abort, context, responseHeaders, highWaterMark } = this
94 const body = new Readable({ resume, abort, contentType, highWaterMark }) field
|
| /third_party/node/benchmark/fs/ |
| D | read-stream-throughput.js | 17 highWaterMark: [1024, 4096, 65535, 1024 * 1024], property
22 const { encodingType, highWaterMark, filesize } = conf;
59 ws.on('close', runTest.bind(null, filesize, highWaterMark, encoding, n));
71 function runTest(filesize, highWaterMark, encoding, n) { argument
74 highWaterMark, property
|
| /third_party/node/deps/undici/src/node_modules/busboy/lib/ |
| D | index.js | 20 highWaterMark: undefined, property
26 if (cfg.highWaterMark)
27 instanceCfg.highWaterMark = cfg.highWaterMark;
|
| /third_party/node/deps/npm/node_modules/node-gyp/node_modules/readable-stream/lib/ |
| D | _stream_transform.js | 89 if (rs.needReadable || rs.length < rs.highWaterMark) {
90 this._read(rs.highWaterMark);
155 …(ts.needTransform || rs.needReadable || rs.length < rs.highWaterMark) this._read(rs.highWaterMark);
|
| /third_party/node/test/fixtures/wpt/streams/piping/ |
| D | error-propagation-forward.any.js | 195 const ws = recordingWritableStream(undefined, new CountQueuingStrategy({ highWaterMark: 0 })); property
217 }, new CountQueuingStrategy({ highWaterMark: 0 })); property
235 const ws = recordingWritableStream(undefined, new CountQueuingStrategy({ highWaterMark: 0 })); property
319 const ws = recordingWritableStream(undefined, new CountQueuingStrategy({ highWaterMark: 0 })); property
344 }, new CountQueuingStrategy({ highWaterMark: 0 })); property
365 const ws = recordingWritableStream(undefined, new CountQueuingStrategy({ highWaterMark: 0 })); property
490 }, new CountQueuingStrategy({ highWaterMark: 2 })); property
540 }, new CountQueuingStrategy({ highWaterMark: 2 })); property
|