Lines Matching refs:Duplex
5 const { Duplex, Readable, Writable, pipeline, PassThrough } = require('stream');
10 const d = Duplex.from({
29 const d = Duplex.from(new Readable({
47 const d = Duplex.from(new Writable({
64 const d = Duplex.from({
83 const d = Duplex.from({
113 const d = Duplex.from(Promise.resolve('asd'));
128 Duplex.from(async function * (source) {
152 const duplex = new Duplex();
153 assert.strictEqual(Duplex.from(duplex), duplex);
156 // Ensure that Duplex.from works for blobs
160 const duplex = Duplex.from(blob);
169 Duplex.from(Promise.reject(myErrorMessage))
182 Duplex.from(asyncFn)
188 // Ensure that Duplex.from throws an Invalid return value when function is void
190 assert.throws(() => Duplex.from(() => {}), {
198 const duplex = Duplex.from({
215 const duplex = Duplex.from({
231 const duplex = Duplex.from({
257 const duplex = Duplex.from(Readable({
270 const duplex = Duplex.from(Writable({
288 .pipe(Duplex.from({
322 const d = Duplex.from({
338 const d = Duplex.from(makeATestReadableStream('foo'));
354 const d = Duplex.from({
370 const d = Duplex.from(makeATestWritableStream((chunk) => ret += chunk));
384 const d = Duplex.from({