Lines Matching refs:rs
18 const rs = new Readable({ constant
22 finished(rs, common.mustSucceed());
24 rs.push(null);
25 rs.resume();
68 const rs = fs.createReadStream(__filename); constant
70 rs.resume();
71 finished(rs, common.mustCall());
78 const rs = fs.createReadStream(__filename);
82 rs.resume();
83 rs.on('end', () => {
86 await finishedPromise(rs);
95 const rs = fs.createReadStream('file-does-not-exist'); constant
97 finished(rs, common.expectsError({
103 const rs = new Readable(); constant
105 finished(rs, common.mustSucceed());
107 rs.push(null);
108 rs.emit('close'); // Should not trigger an error
109 rs.resume();
113 const rs = new Readable(); constant
115 finished(rs, common.mustCall((err) => {
119 rs.emit('close'); // Should trigger error
120 rs.push(null);
121 rs.resume();
126 const rs = new Readable({ constant
131 () => finished(rs, 'foo'),
138 () => finished(rs, 'foo', () => {}),
145 () => finished(rs, {}, 'foo'),
152 finished(rs, null, common.mustCall());
154 rs.push(null);
155 rs.resume();
171 const rs = new Readable(); constant
172 const removeListeners = finished(rs, common.mustNotCall());
175 rs.emit('close');
176 rs.push(null);
177 rs.resume();
327 const rs = fs.createReadStream(__filename, { autoClose: false }); constant
328 rs.resume();
329 rs.on('close', common.mustNotCall());
330 rs.on('end', common.mustCall(() => {
331 finished(rs, common.mustCall());