| /third_party/node/test/fixtures/wpt/streams/writable-streams/ |
| D | general.any.js | 5 const ws = new WritableStream({});
13 const ws = new WritableStream({});
21 const ws = new WritableStream({});
33 const ws = new WritableStream({
44 const ws = new WritableStream({});
54 const ws = new WritableStream({});
65 const ws = new WritableStream({});
75 const ws = new WritableStream({
93 const ws = new WritableStream({});
144 const ws = new WritableStream(theSink);
[all …]
|
| D | close.any.js | 13 const ws = new WritableStream({
29 const ws = new WritableStream({
58 const ws = new WritableStream({
73 const ws = new WritableStream({
90 const ws = new WritableStream({
107 const ws = new WritableStream({
199 const ws = new WritableStream({
210 const ws = new WritableStream();
224 const ws = new WritableStream({
243 const ws = new WritableStream({
[all …]
|
| D | constructor.any.js | 12 const ws = new WritableStream({
30 const ws = new WritableStream({
47 const ws = new WritableStream({
59 const ws = new WritableStream({}, {
73 const ws = new WritableStream({}, {
87 new WritableStream();
96 assert_throws_exactly(error2, () => new WritableStream(underlyingSink, queuingStrategy));
100 const ws = new WritableStream({});
118 new WritableStream({
130 const stream = new WritableStream({
[all …]
|
| D | bad-underlying-sinks.any.js | 11 new WritableStream({
19 new WritableStream({
27 new WritableStream({
33 new WritableStream({
75 assert_throws_exactly(error1, () => new WritableStream({
83 assert_throws_exactly(error1, () => new WritableStream({
91 const ws = new WritableStream({
161 assert_throws_js(TypeError, () => new WritableStream({
167 assert_throws_js(TypeError, () => new WritableStream({
173 assert_throws_js(TypeError, () => new WritableStream({
[all …]
|
| D | aborting.any.js | 13 const ws = new WritableStream({
33 const ws = new WritableStream();
49 const ws = new WritableStream();
107 const ws = new WritableStream({
121 const ws = new WritableStream({
133 const ws = new WritableStream({
149 const ws = new WritableStream({
161 const ws = new WritableStream({
195 const ws = new WritableStream();
220 const ws = new WritableStream();
[all …]
|
| D | bad-strategies.any.js | 9 new WritableStream({}, {
20 new WritableStream({}, { size: 'a string' });
26 new WritableStream({}, {
41 new WritableStream({}, {
52 const ws = new WritableStream({}, {
71 const ws = new WritableStream({}, {
91 assert_throws_js(TypeError, () => new WritableStream(undefined, {
|
| D | write.any.js | 19 const ws = new WritableStream({
52 const ws = new WritableStream({
68 const ws = new WritableStream({
112 const ws = new WritableStream({
158 const ws = new WritableStream({
172 const ws = new WritableStream({
199 const ws = new WritableStream({
242 const ws = new WritableStream({
256 const stream = new WritableStream();
267 const ws = new WritableStream({
[all …]
|
| D | error.any.js | 11 const ws = new WritableStream({
21 const ws = new WritableStream({
32 const ws = new WritableStream({
44 const ws = new WritableStream({
56 const ws = new WritableStream({
|
| D | count-queuing-strategy.any.js | 5 new WritableStream({}, new CountQueuingStrategy({ highWaterMark: 4 }));
11 const ws = new WritableStream(
58 const ws = new WritableStream(
|
| D | start.any.js | 66 new WritableStream({
95 const ws = new WritableStream({
150 const ws = new WritableStream({
|
| /third_party/node/test/parallel/ |
| D | test-whatwg-writablestream.js | 8 WritableStream,
53 const stream = new WritableStream();
64 assert.throws(() => new WritableStream({ type }), {
70 assert.throws(() => new WritableStream({}, { highWaterMark }), {
76 assert.throws(() => new WritableStream({}, { size }), {
82 new WritableStream({}, 1);
83 new WritableStream({}, 'a');
84 new WritableStream({}, null);
89 const stream = new WritableStream(
124 const stream = new WritableStream(
[all …]
|
| D | test-whatwg-webstreams-adapters-to-streamwritable.js | 9 WritableStream,
58 const writableStream = new WritableStream(source);
77 const writableStream = new WritableStream(source);
96 const writableStream = new WritableStream(source);
121 const writableStream = new WritableStream(source);
147 const writableStream = new WritableStream(source);
163 const writableStream = new WritableStream(source);
182 const writableStream = new WritableStream(source);
202 const writableStream = new WritableStream({
219 const writableStream = new WritableStream({
|
| D | test-webstreams-pipeline.js | 7 const { ReadableStream, WritableStream, TransformStream } = require('stream/web');
18 const ws = new WritableStream({
41 const ws = new WritableStream({
67 const ws = new WritableStream({
98 const ws = new WritableStream({
122 const ws = new WritableStream({
171 const ws = new WritableStream({
270 const ws = new WritableStream({
293 const ws = new WritableStream({
375 const ws = new WritableStream({
[all …]
|
| D | test-webstreams-finished.js | 5 const { ReadableStream, WritableStream } = require('stream/web');
156 const ws = new WritableStream({
172 const ws = new WritableStream({
190 const ws = new WritableStream({
206 const ws = new WritableStream({
218 const ws = new WritableStream({
|
| D | test-whatwg-webstreams-transfer.js | 8 WritableStream,
186 const writable = new WritableStream({
352 const writable = new WritableStream(source);
395 const writable = new WritableStream(source);
421 const writable = new WritableStream(source);
542 const writable = new WritableStream(source);
565 const writable = new WritableStream();
|
| D | test-stream-duplex.js | 26 const { ReadableStream, WritableStream } = require('stream/web');
69 const writable = new WritableStream({
95 const writable = new WritableStream({
|
| /third_party/node/test/fixtures/wpt/streams/piping/ |
| D | pipe-through.any.js | 12 writable: new WritableStream({
32 return { writable: new WritableStream(), readable: new ReadableStream() };
44 writable: new WritableStream({
73 const writable = new WritableStream();
91 const writable = new WritableStream();
115 return new WritableStream();
125 const badWritables = [null, undefined, 0, NaN, true, 'WritableStream', Object.create(WritableStream…
201 const writable = new WritableStream();
210 const writable = new WritableStream();
219 const writable = new WritableStream({
[all …]
|
| D | general.any.js | 9 const ws = new WritableStream();
28 const ws = new WritableStream();
40 const ws = new WritableStream();
49 const fakeWS = Object.create(WritableStream.prototype);
58 const ws = new WritableStream();
74 const ws = new WritableStream();
101 const ws = new WritableStream({
163 return rs.pipeTo(new WritableStream(), { preventAbort }).then(
179 const ws = new WritableStream({
194 const ws = new WritableStream();
[all …]
|
| D | abort.any.js | 38 const ws = new WritableStream();
59 const ws = new WritableStream();
81 const ws = new WritableStream();
195 const ws = new WritableStream();
204 const ws = new WritableStream({
226 const ws = new WritableStream({
245 const ws = new WritableStream();
258 const ws = new WritableStream();
271 const ws = new WritableStream();
288 const ws = new WritableStream({
[all …]
|
| /third_party/node/test/fixtures/wpt/streams/transferable/ |
| D | transfer-with-messageport.window.js | 118 const writable = new WritableStream();
136 const writable = new WritableStream();
149 const writable1 = new WritableStream();
150 const writable2 = new WritableStream();
180 await transferMessagePortWith(WritableStream);
192 await transferMessagePortWith(WritableStream);
211 postMessage({ stream: new WritableStream() }, "*")
|
| /third_party/node/test/fixtures/wpt/streams/transform-streams/ |
| D | patched-global.any.js | 30 const oldWritableStream = WritableStream;
32 const getWriter = WritableStream.prototype.getWriter;
38 WritableStream = function () { class
43 WritableStream = oldWritableStream;
|
| /third_party/node/deps/undici/src/node_modules/@fastify/busboy/lib/ |
| D | main.js | 3 const WritableStream = require('node:stream').Writable constant
33 WritableStream.call(this, this.opts)
39 inherits(Busboy, WritableStream)
51 WritableStream.prototype.emit.apply(this, arguments) class
|
| /third_party/node/doc/api/ |
| D | webstreams.md | 27 * `WritableStream` - Represents a destination for streaming data.
206 * `writable` {WritableStream} The `WritableStream` to which this
221 {WritableStream} provided in the `transform` argument such that the
285 * `destination` {WritableStream} A {WritableStream} to which this
764 ### Class: `WritableStream`
774 The `WritableStream` is a destination to which stream data is sent.
778 WritableStream,
781 const stream = new WritableStream({
790 #### `new WritableStream([underlyingSink[, strategy]])` argument
798 the `WritableStream` is created.
[all …]
|
| /third_party/node/test/fixtures/wpt/interfaces/ |
| D | streams.idl | 15 Promise<undefined> pipeTo(WritableStream destination, optional StreamPipeOptions options = {});
35 required WritableStream writable;
123 interface WritableStream {
148 constructor(WritableStream stream);
172 readonly attribute WritableStream writable;
225 readonly attribute WritableStream writable;
|
| /third_party/node/deps/undici/src/node_modules/@fastify/busboy/deps/dicer/lib/ |
| D | Dicer.js | 3 const WritableStream = require('node:stream').Writable constant
18 WritableStream.call(this, cfg)
47 inherits(Dicer, WritableStream)
71 } else { WritableStream.prototype.emit.apply(this, arguments) } class
|