Lines Matching refs:stream
11 } = require('stream/web');
35 const stream = new TransformStream();
37 async function test(stream) {
38 const writer = stream.writable.getWriter();
39 const reader = stream.readable.getReader();
49 test(stream).then(common.mustCall());
68 const stream = new TransformStream(transform);
71 async function test(stream) {
72 const writer = stream.writable.getWriter();
73 const reader = stream.readable.getReader();
85 test(stream).then(common.mustCall(() => {
96 this.stream = createReadStream(__filename);
97 this.stream.on('data', (chunk) => {
100 this.stream.once('end', () => {
104 this.stream.once('error', (error) => {
119 async function read(stream) {
121 for await (const chunk of stream)