-
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy path7-pull.js
More file actions
29 lines (24 loc) · 588 Bytes
/
Copy path7-pull.js
File metadata and controls
29 lines (24 loc) · 588 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
'use strict';
// Pull-based ReadableStream: data produced only when the consumer reads
const countStream = (max) => {
let n = 0;
return new ReadableStream({
pull(controller) {
n += 1;
console.log('pull produced', n);
controller.enqueue(n);
if (n >= max) controller.close();
},
});
};
// Usage
const main = async () => {
const reader = countStream(3).getReader();
console.log('reader created (no pull yet)');
while (true) {
const { done, value } = await reader.read();
if (done) break;
console.log('got', value);
}
};
main();