| /third_party/node/test/parallel/ |
| H A D | test-stream-map.js | 5 Readable,
32 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => x + x);
40 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
51 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
61 const stream = Readable.from(async function* () {
77 const stream = new Readable({
96 const source = new Readable({
117 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
131 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => {
146 const stream = Readable
[all...] |
| H A D | test-stream-reduce.js | 5 Readable,
26 const streamReduce = await Readable.from(values)
34 const streamReduce = await Readable.from(values)
45 const six = await Readable.from([1, 2, 3]).reduce(async (p, c) => p + c, 0);
49 const six = await Readable.from([1, 2, 3]).reduce(async (p, c) => p + c);
55 assert.rejects(Readable.from([1, 2, 3, 4, 5, 6])
72 await Readable.from([1, 2, 3]).reduce(async (p, c) => {
87 const stream = Readable.from([1, 2, 3]);
104 const stream = Readable.from([1, 2, 3]);
122 assert.rejects(() => Readable
[all...] |
| H A D | test-stream-readable-async-iterators.js | 6 Readable,
28 stream[Symbol.asyncIterator] = Readable.prototype[Symbol.asyncIterator];
46 const iter = Readable.prototype[Symbol.asyncIterator].call(stream);
57 const readable = new Readable({ autoDestroy: false, read() {} });
73 const readable = new Readable({ objectMode: true, read() {} });
88 const readable = new Readable({
117 const readable = new Readable({
158 const readable = new Readable({
202 const readable = new Readable({
217 const readable = new Readable({
[all...] |
| H A 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 {
[all...] |
| H A D | test-stream-readable-event.js | 26 const Readable = require('stream').Readable;
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();
|
| H A D | test-stream-readable-didRead.js | 4 const { isDisturbed, isErrored, Readable } = require('stream');
42 const readable = new Readable({
53 const readable = new Readable({
64 const readable = new Readable({
75 const readable = new Readable({
87 const readable = new Readable({
100 const readable = new Readable({
|
| H A D | test-stream-finished.js | 6 Readable,
20 const rs = new Readable({
101 const rs = Readable.from((function* () {})());
112 const rs = Readable.from((function* () {})());
125 const rs = Readable.from((function* () {})());
137 const rs = Readable.from((function* () {
151 const rs = Readable.from((function* () {})());
165 const rs = Readable.from((function* () {})());
182 const rs = new Readable();
192 const rs = new Readable();
[all...] |
| H A 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);
|
| H A D | test-stream-flatMap.js | 6 Readable,
13 return Readable.from([1, 2, 3, 4, 5]);
53 return Readable.from([x, x]);
112 assert.throws(() => Readable.from([1]).flatMap(1), /ERR_INVALID_ARG_TYPE/);
113 assert.throws(() => Readable.from([1]).flatMap((x) => x, {
116 assert.throws(() => Readable.from([1]).flatMap((x) => x, 1), /ERR_INVALID_ARG_TYPE/);
117 assert.throws(() => Readable.from([1]).flatMap((x) => x, { signal: true }), /ERR_INVALID_ARG_TYPE/);
120 // Test result is a Readable
|
| H A 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();
|
| H A D | test-stream2-objects.js | 25 const { Readable, Writable } = require('stream');
43 const r = new Readable({ objectMode: true });
88 const r = new Readable({ objectMode: true });
105 const r = new Readable({ objectMode: true });
124 const r = new Readable({
141 const r = new Readable({
156 const r = new Readable({
173 const r = new Readable({
204 const r = new Readable({
|
| H A D | test-stream-pipe-event.js | 34 function Readable() { class
38 Object.setPrototypeOf(Readable.prototype, stream.Stream.prototype);
39 Object.setPrototypeOf(Readable, stream.Stream);
48 const r = new Readable();
|
| H A D | test-stream-readable-object-multi-push-async.js | 5 const { Readable } = require('stream');
11 const readable = new Readable({
61 const readable = new Readable({
107 const readable = new Readable({
148 const readable = new Readable({
168 const readable = new Readable({
|
| H A D | test-stream-pipeline.js | 7 Readable,
30 const read = new Readable({
57 const read = new Readable({
73 const read = new Readable({
92 const read = new Readable({
113 const read = new Readable({
150 const rs = new Readable({
183 const rs = new Readable({
218 const rs = new Readable({
269 const rs = new Readable({
[all...] |
| H A D | test-event-emitter-prepend.js | 33 function Readable() { class
37 Object.setPrototypeOf(Readable.prototype, stream.Stream.prototype);
38 Object.setPrototypeOf(Readable, stream.Stream);
41 const r = new Readable();
|
| H A D | test-stream-readable-no-unneeded-readable.js | 3 const { Readable, PassThrough } = require('stream');
6 const wrapper = new Readable({
34 const source = new Readable({
48 const r = new Readable({
|
| H A D | test-stream-construct.js | 4 const { Writable, Readable, Duplex } = require('stream');
22 new Readable({
49 new Readable({
75 new Readable({
168 testDestroy((opts) => new Readable({
180 const r = new Readable({
274 new Readable({
|
| H A D | test-stream-readable-reading-readingMore.js | 4 const Readable = require('stream').Readable;
7 const readable = new Readable({
67 const readable = new Readable({
117 const readable = new Readable({
|
| H A D | test-stream-end-paused.js | 28 const Readable = require('stream').Readable;
29 const stream = new Readable();
|
| H A D | test-stream-push-order.js | 24 const Readable = require('stream').Readable;
27 const s = new Readable({
|
| H A D | test-stream2-read-sync-stack.js | 24 const Readable = require('stream').Readable;
29 const r = new Readable();
|
| /third_party/node/lib/internal/streams/ |
| H A D | readable.js | 39 module.exports = Readable;
40 Readable.ReadableState = ReadableState;
79 ObjectSetPrototypeOf(Readable.prototype, Stream.prototype);
80 ObjectSetPrototypeOf(Readable, Stream);
221 function Readable(options) { class
222 if (!(this instanceof Readable))
223 return new Readable(options);
254 Readable.prototype.destroy = destroyImpl.destroy;
255 Readable.prototype._undestroy = destroyImpl.undestroy;
256 Readable
262 Readable.prototype[SymbolAsyncDispose] = function() { global() function
[all...] |
| /third_party/node/benchmark/streams/ |
| H A D | destroy.js | 5 Readable,
27 new Readable({});
28 new Readable();
32 new Readable().destroy();
|
| H A D | creation.js | 5 Readable,
27 new Readable({});
28 new Readable();
32 new Readable();
|
| H A D | readable-bigunevenread.js | 4 const Readable = require('stream').Readable;
12 const s = new Readable();
|