| /third_party/node/test/parallel/ |
| D | test-readable-from.js | 5 const { Readable } = require('stream');
15 const stream = Readable.from(generate());
31 const stream = Readable.from(generate());
47 const stream = Readable.from(promises);
57 const stream = Readable.from('abc');
67 const stream = Readable.from(Buffer.from('abc'));
83 const stream = Readable.from(generate());
105 const stream = Readable.from(generate(), { objectMode: false });
126 const stream = Readable.from(generate());
143 const source = new Readable({
[all …]
|
| D | test-stream-readable-destroy.js | 4 const { Readable } = require('stream');
8 const read = new Readable({
20 const read = new Readable({
38 const read = new Readable({
60 const read = new Readable({
81 const read = new Readable({
95 const read = new Readable({
121 const read = new Readable({
149 const read = new Readable({
166 Readable.call(this);
[all …]
|
| D | test-stream-readable-async-iterators.js | 6 Readable,
27 stream[Symbol.asyncIterator] = Readable.prototype[Symbol.asyncIterator];
45 const iter = Readable.prototype[Symbol.asyncIterator].call(stream);
56 const readable = new Readable({ autoDestroy: false, read() {} });
72 const readable = new Readable({ objectMode: true, read() {} });
87 const readable = new Readable({
116 const readable = new Readable({
157 const readable = new Readable({
201 const readable = new Readable({
216 const readable = new Readable({
[all …]
|
| D | test-stream-readable-didRead.js | 4 const Readable = require('stream').Readable; constant
35 const readable = new Readable({
46 const readable = new Readable({
57 const readable = new Readable({
68 const readable = new Readable({
80 const readable = new Readable({
93 const readable = new Readable({
|
| D | test-stream-readable-unshift.js | 5 const { Readable } = require('stream');
9 const readable = new Readable({ read() {} });
24 const readable = new Readable({ read() {} });
40 const readable = new Readable({ read() {} });
82 const r1 = new Readable({ read() {} });
86 const r2 = new Readable({ read() {}, encoding: streamEncoding });
106 const r1 = new Readable({ read() {} });
110 const r2 = new Readable({ read() {}, encoding });
117 const readable = new Readable({ objectMode: true, read() {} });
134 class ArrayReader extends Readable {
|
| D | test-stream-readable-event.js | 26 const Readable = require('stream').Readable; constant
31 const r = new Readable({
51 const r = new Readable({
70 const r = new Readable({
94 const r = new Readable({
119 const r = new Readable();
|
| D | test-readable-from-iterator-closing.js | 4 const { Readable } = require('stream');
19 const stream = Readable.from(infiniteGenerate());
40 const stream = Readable.from(infiniteGenerate());
65 const stream = Readable.from(infiniteGenerate());
93 const stream = Readable.from(generate());
110 const stream = Readable.from({
154 const stream = Readable.from(infiniteGenerate());
181 const stream = Readable.from(generate());
|
| D | test-stream-inheritance.js | 4 const { Readable, Writable, Duplex, Transform } = require('stream');
6 const readable = new Readable({ read() {} });
11 assert.ok(readable instanceof Readable);
12 assert.ok(!(writable instanceof Readable));
13 assert.ok(duplex instanceof Readable);
14 assert.ok(transform instanceof Readable);
|
| D | test-stream-readable-needReadable.js | 4 const Readable = require('stream').Readable; constant
6 const readable = new Readable({
30 const asyncReadable = new Readable({
54 const flowing = new Readable({
72 const slowProducer = new Readable({
|
| D | test-streams-highwatermark.js | 17 const readable = stream.Readable({ highWaterMark: ovfl });
26 for (const type of [stream.Readable, stream.Writable]) {
44 const readable = stream.Readable({ highWaterMark: 0 });
57 const readable = stream.Readable({ highWaterMark: 0 });
66 const readable = new stream.Readable({
|
| D | test-stream-pipe-cleanup.js | 44 function Readable() { class
48 Object.setPrototypeOf(Readable.prototype, stream.Stream.prototype);
49 Object.setPrototypeOf(Readable, stream.Stream);
66 r = new Readable();
76 r = new Readable();
85 r = new Readable();
94 r = new Readable();
|
| /third_party/node/deps/npm/node_modules/sorted-union-stream/ |
| D | test.js | 1 var Readable = require('stream').Readable variable
6 var a = new Readable({objectMode: true})
7 var b = new Readable({objectMode: true})
38 var a = new Readable({objectMode: true})
39 var b = new Readable({objectMode: true})
70 var a = new Readable({objectMode: true})
71 var b = new Readable({objectMode: true})
102 var a = new Readable({objectMode: true})
103 var b = new Readable({objectMode: true})
137 var a = new Readable({objectMode: true})
[all …]
|
| /third_party/node/deps/npm/node_modules/isstream/ |
| D | test.js | 73 test(true, 'CoreStreams.Readable', new (CoreStreams.Readable)())
79 test(true, 'ReadableStream10.Readable', new (ReadableStream10.Readable)())
85 test(true, 'ReadableStream11.Readable', new (ReadableStream11.Readable)())
93 testReadable(true, 'CoreStreams.Readable', new (CoreStreams.Readable)())
99 testReadable(true, 'ReadableStream10.Readable', new (ReadableStream10.Readable)())
105 testReadable(true, 'ReadableStream11.Readable', new (ReadableStream11.Readable)())
113 testWritable(false, 'CoreStreams.Readable', new (CoreStreams.Readable)())
119 testWritable(false, 'ReadableStream10.Readable', new (ReadableStream10.Readable)())
125 testWritable(false, 'ReadableStream11.Readable', new (ReadableStream11.Readable)())
133 testDuplex(false, 'CoreStreams.Readable', new (CoreStreams.Readable)())
[all …]
|
| /third_party/node/deps/npm/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 23 module.exports = Readable;
29 Readable.ReadableState = ReadableState;
90 require('inherits')(Readable, Stream);
169 function Readable(options) { class
171 …if (!(this instanceof Readable)) return new Readable(options); // Checking for a Stream.Duplex ins…
187 Object.defineProperty(Readable.prototype, 'destroyed', {
211 Readable.prototype.destroy = destroyImpl.destroy;
212 Readable.prototype._undestroy = destroyImpl.undestroy;
214 Readable.prototype._destroy = function (err, cb) {
222 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/sorted-union-stream/node_modules/readable-stream/ |
| D | float.patch | 9 -var Readable = require('_stream_readable');
11 +var Readable = require('./_stream_readable');
14 util.inherits(Duplex, Readable);
33 @@ -23,10 +23,34 @@ module.exports = Readable;
34 Readable.ReadableState = ReadableState;
67 util.inherits(Readable, Stream);
118 // instanceof Writable, they're instanceof Readable.
136 var r = new stream.Readable({
145 -var Readable = require('stream').Readable;
146 +var Readable = require('../../').Readable;
[all …]
|
| /third_party/node/lib/internal/streams/ |
| D | readable.js | 36 module.exports = Readable;
37 Readable.ReadableState = ReadableState;
65 ObjectSetPrototypeOf(Readable.prototype, Stream.prototype);
66 ObjectSetPrototypeOf(Readable, Stream);
170 function Readable(options) { class
171 if (!(this instanceof Readable))
172 return new Readable(options);
191 Readable.prototype.destroy = destroyImpl.destroy;
192 Readable.prototype._undestroy = destroyImpl.undestroy;
193 Readable.prototype._destroy = function(err, cb) {
[all …]
|
| /third_party/node/deps/npm/node_modules/are-we-there-yet/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/stream-iterate/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/parallel-transform/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/from2/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/fs-write-stream-atomic/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/duplexify/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/concat-stream/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/flush-write-stream/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|
| /third_party/node/deps/npm/node_modules/through2/node_modules/readable-stream/lib/ |
| D | _stream_readable.js | 29 module.exports = Readable;
39 Readable.ReadableState = ReadableState;
85 util.inherits(Readable, Stream);
178 function Readable(options) { class
181 if (!(this instanceof Readable)) return new Readable(options);
197 Object.defineProperty(Readable.prototype, 'destroyed', {
217 Readable.prototype.destroy = destroyImpl.destroy;
218 Readable.prototype._undestroy = destroyImpl.undestroy;
219 Readable.prototype._destroy = function (err, cb) {
228 Readable.prototype.push = function (chunk, encoding) {
[all …]
|