Lines Matching refs:read
30 const read = new Readable({
31 read() {}
46 read.push(expected[i]);
48 read.push(null);
50 pipeline(read, write, common.mustSucceed(() => {
57 const read = new Readable({
58 read() {}
62 pipeline(read, () => {});
73 const read = new Readable({
74 read() {}
83 read.push('data');
84 setImmediate(() => read.destroy());
86 pipeline(read, write, common.mustCall((err) => {
92 const read = new Readable({
93 read() {}
102 read.push('data');
103 setImmediate(() => read.destroy(new Error('kaboom')));
105 const dst = pipeline(read, write, common.mustCall((err) => {
113 const read = new Readable({
114 read() {}
129 read.on('close', common.mustCall());
133 [read, transform, write].forEach((stream) => {
139 const dst = pipeline(read, transform, write, common.mustCall((err) => {
145 read.push('hello');
151 read() {
184 read() {
219 read() {
270 read() {
305 read() {
356 read() {
414 read() {
447 const read = new Readable({
448 read() {}
457 read.push('data');
458 read.push(null);
466 await pipelinePromise(read, write);
545 const read = new Readable({
546 read() {}
562 () => pipeline(read, transform, write),
818 // v1 streams without read().
841 // v1 error streams without read().
1048 read() {
1138 read() {},
1160 read() {},
1196 read: common.mustCall(() => {
1240 read: common.mustCall(() => {
1269 read() {}
1454 const read = new Readable({
1455 read() {}
1460 read.push(null);
1462 await pipelinePromise(read, duplex);
1474 const read = new Readable({
1475 read() {}
1480 read.push(null);
1482 await pipelinePromise(read, duplex, { end: false });
1597 read() {}
1603 readable.read();
1608 read() {},
1617 dup.read();