Lines Matching refs:common
3 const common = require('../common');
50 pipeline(read, write, common.mustSucceed(() => {
86 pipeline(read, write, common.mustCall((err) => {
105 const dst = pipeline(read, write, common.mustCall((err) => {
129 read.on('close', common.mustCall());
130 transform.on('close', common.mustCall());
131 write.on('close', common.mustCall());
134 stream.on('error', common.mustCall((err) => {
139 const dst = pipeline(read, transform, write, common.mustCall((err) => {
169 res.on('end', common.mustCall(() => {
191 destroy: common.mustCall((err, cb) => {
225 destroy: common.mustCall((err, cb) => {
250 pipeline(res, badSink, common.mustCall((err) => {
260 pipeline(req, res, common.mustSucceed());
278 pipeline(rs, req, common.mustCall(() => {
300 tr.on('close', common.mustCall());
320 rs.on('close', common.mustCall());
321 ws.on('close', common.mustCall());
332 common.mustCall((err) => {
381 common.mustSucceed(() => {
402 destroyableOldStream.destroy = common.mustCall(() => {
436 common.mustCall((err) => {
494 assert.rejects(run, { name: 'AbortError' }).then(common.mustCall());
519 assert.rejects(run, { name: 'AbortError' }).then(common.mustCall());
541 assert.rejects(run, { name: 'AbortError' }).then(common.mustCall());
575 stream.on('error', common.mustCall());
580 common.mustCall((err) => {
587 }).on('error', common.mustNotCall());
602 }(), w, common.mustSucceed(() => {
619 }(), w, common.mustSucceed(() => {
635 }, w, common.mustSucceed(() => {
652 }, w, common.mustSucceed(() => {
671 }, common.mustSucceed(() => {
691 }, common.mustSucceed((val) => {
704 }, common.mustCall((err) => {
720 }, common.mustCall((err) => {
731 }, s, common.mustCall((err) => {
741 }(), s, common.mustCall((err) => {
751 }, s, common.mustCall((err, val) => {
761 }(), s, common.mustCall((err, val) => {
777 }, common.mustCall((err, val) => {
791 }, common.mustCall((err) => {
811 }, common.mustCall((err) => {
828 s.close = common.mustCallAtLeast(1);
834 }, common.mustCall((err) => {
847 s.destroy = common.mustCall();
849 }, common.mustCall((err) => {
916 }, common.mustCall((err) => {
936 }, common.mustCall((err) => {
957 }, common.mustSucceed(() => {
969 }, common.mustCall((err) => {
977 pipeline(src, dst, common.mustCall(() => {
1015 common.mustSucceed(() => {
1029 pipeline(src, dst, common.mustSucceed(() => {
1039 pipeline(src, dst, common.mustSucceed(() => {
1055 write: common.mustNotCall()
1065 }, ws, common.mustCall((err) => {
1073 req.socket.on('error', common.mustNotCall());
1087 req.on('response', common.mustCall());
1088 req.on('error', common.mustNotCall());
1101 pipeline(src, dst, common.mustCall((err) => {
1117 common.mustCall((err) => {
1132 }, common.mustSucceed());
1152 pipeline(src, dst, common.mustCall((err) => {
1166 src.on('close', common.mustCall(() => {
1170 pipeline(src, dst, common.mustCall((err) => {
1176 const server = net.createServer(common.mustCall((socket) => {
1178 pipeline(socket, socket, common.mustSucceed());
1180 socket.on('finish', common.mustCall(() => {
1183 })).listen(0, common.mustCall(() => {
1192 write: common.mustCall((data, enc, cb) => {
1196 read: common.mustCall(() => {
1199 final: common.mustCall((cb) => {
1205 destroy: common.mustNotCall()
1209 write: common.mustCall((data, enc, cb) => {
1214 pipeline(d, sink, common.mustSucceed());
1221 const server = net.createServer(common.mustCall((socket) => {
1223 pipeline(socket, socket, common.mustSucceed());
1224 socket.on('finish', common.mustCall(() => {
1227 })).listen(0, common.mustCall(() => {
1236 write: common.mustCall((data, enc, cb) => {
1240 read: common.mustCall(() => {
1243 final: common.mustCall((cb) => {
1252 destroy: common.mustNotCall()
1256 write: common.mustCall((data, enc, cb) => {
1261 pipeline(d, sink, common.mustSucceed());
1281 pipeline([r, w], common.mustSucceed(() => {
1304 common.mustCall(() => {
1327 () => common.mustNotCall(),
1350 const cb = common.mustCall((err) => {
1362 common.mustSucceed(() => {}));
1371 pipeline(['1', '2', '3'], w, common.mustSucceed(() => {
1379 common.mustSucceed(() => {}));
1387 }, common.mustSucceed(() => {
1403 ).catch(common.mustCall((err) => {
1444 pipeline([Readable.from('Hello World!'), write], common.mustSucceed(() => {
1467 run().then(common.mustCall());
1488 run().then(common.mustCall());
1508 }, common.mustCall((err, val) => {
1524 }, common.mustCall((err, val) => {
1539 writable.on('error', common.mustCall((err) => {
1554 common.mustCall((err) => {
1589 pipeline(readable, writable, common.mustSucceed(() => {
1599 readable.on('end', common.mustCall(() => {
1600 pipeline(readable, new PassThrough(), common.mustSucceed());
1613 dup.on('end', common.mustCall(() => {
1614 pipeline(dup, new PassThrough(), common.mustSucceed());
1632 }, writable, { end: false }).then(common.mustCall(() => {
1654 final: common.mustCall((cb) => {
1660 pipeline(r, w, common.mustCall((err) => {