• Home
  • Raw
  • Download

Lines Matching refs:rs

20   const rs = new Readable({  constant
24 finished(rs, common.mustSucceed());
26 rs.push(null);
27 rs.resume();
70 const rs = fs.createReadStream(__filename); constant
72 rs.resume();
73 finished(rs, common.mustCall());
80 const rs = fs.createReadStream(__filename);
84 rs.resume();
85 rs.on('end', () => {
88 await finishedPromise(rs);
101 const rs = Readable.from((function* () {})()); constant
102 finished(rs, { signal }, common.mustCall((err) => {
112 const rs = Readable.from((function* () {})()); constant
113 finished(rs, { signal }, common.mustCall((err) => {
125 const rs = Readable.from((function* () {})()); constant
127 finished(rs, { signal }, common.mustCall((err) => {
137 const rs = Readable.from((function* () { constant
141 rs.resume();
142 finished(rs, { signal }, common.mustSucceed());
151 const rs = Readable.from((function* () {})());
153 await finishedPromise(rs, { signal });
165 const rs = Readable.from((function* () {})());
166 await finishedPromise(rs, { signal });
174 const rs = fs.createReadStream('file-does-not-exist'); constant
176 finished(rs, common.expectsError({
182 const rs = new Readable(); constant
184 finished(rs, common.mustSucceed());
186 rs.push(null);
187 rs.emit('close'); // Should not trigger an error
188 rs.resume();
192 const rs = new Readable(); constant
194 finished(rs, common.mustCall((err) => {
198 rs.emit('close'); // Should trigger error
199 rs.push(null);
200 rs.resume();
205 const rs = new Readable({ constant
210 () => finished(rs, 'foo'),
217 () => finished(rs, 'foo', () => {}),
224 () => finished(rs, {}, 'foo'),
231 finished(rs, null, common.mustCall());
233 rs.push(null);
234 rs.resume();
250 const rs = new Readable(); constant
251 const removeListeners = finished(rs, common.mustNotCall());
254 rs.emit('close');
255 rs.push(null);
256 rs.resume();
411 const rs = fs.createReadStream(__filename, { autoClose: false }); constant
412 rs.resume();
413 rs.on('close', common.mustNotCall());
414 rs.on('end', common.mustCall(() => {
415 finished(rs, common.mustCall());