Lines Matching refs:pipe

168         stream.pipe(csvStream);
197         csvStream.pipe(stream);
6076             if (iterable.pipe && !iterable[Symbol.asyncIterator]) {
6077               iterable = iterable.pipe(new PassThrough());
6514               write = function write(pipe) {
6516                   pipe.write(chunk.toBuffer(), function () {
6684         _this3.pipes.forEach(function (pipe) {
6685           pipe.end();
6743   pipe: function pipe(destination) {
6753     this.pipes = this.pipes.filter(function (pipe) {
6754       return pipe !== destination;
7628     value: function pipe(destination, options) {
7629       return this.stream.pipe(destination, options);
24232                   entry.pipe(streamBuf);
24360                   entry.pipe(stream);
24398                 if (!stream[Symbol.asyncIterator] && stream.pipe) {
24399                   stream = stream.pipe(new PassThrough());
25380                 zip.pipe(stream);
26168   return exports.write(rows, options).pipe(ws);
26184     exports.write(rows, opts).pipe(ws);
26198   return exports.write(rows, options).pipe(stream);
26681 …return stream.pipe(new CsvParserStream_1.CsvParserStream(new ParserOptions_1.ParserOptions(options…
26686 …return fs.createReadStream(location).pipe(new CsvParserStream_1.CsvParserStream(new ParserOptions_…
26693   return rs.pipe(new CsvParserStream_1.CsvParserStream(new ParserOptions_1.ParserOptions(options)));
50878 …er(external.Promise.resolve(this.compressedContent)).pipe(this.compression.uncompressWorker()).pip…
50906 …ressedWorker.pipe(new Crc32Probe()).pipe(new DataLengthProbe("uncompressedSize")).pipe(compression…
51725       }).pipe(zipFileWorker);
51815     var worker = zipEntry.decompressed.getContentWorker().pipe(new Crc32Probe());
53219   pipe: function pipe(next) {
53525 …this._worker = worker.pipe(new ConvertWorker(internalType)); // the last workers can be rewired wi…
55140         result = result.pipe(new utf8.Utf8EncodeWorker());
55144         result = result.pipe(new utf8.Utf8DecodeWorker());
55188         result = result.pipe(new utf8.Utf8EncodeWorker());
72230 Readable.prototype.pipe = function (dest, pipeOpts) {
73210 Writable.prototype.pipe = function () {
74432 function pipe(from, to) {
74433   return from.pipe(to);
74466   return streams.reduce(pipe);
78916 Stream.prototype.pipe = function (dest, options) {
79717 Readable.prototype.pipe = function (dest, pipeOpts) {
80684 Writable.prototype.pipe = function () {