1 | import { AsyncIterableX } from './asynciterablex';
|
2 | import { Transform } from 'stream';
|
3 | const asyncIterableMixin = Symbol('asyncIterableMixin');
|
4 | let AsyncIterableTransform = (() => {
|
5 | var _a;
|
6 | class AsyncIterableTransform extends Transform {
|
7 | constructor(options) {
|
8 | super(options);
|
9 |
|
10 |
|
11 | if (!AsyncIterableTransform[asyncIterableMixin]) {
|
12 | AsyncIterableTransform[asyncIterableMixin] = true;
|
13 | Object.defineProperties(AsyncIterableTransform.prototype, Object.getOwnPropertyDescriptors(AsyncIterableX.prototype));
|
14 | }
|
15 | }
|
16 |
|
17 | _flush(callback) {
|
18 | callback();
|
19 | }
|
20 |
|
21 | _transform(chunk, _encoding, callback) {
|
22 | callback(null, chunk);
|
23 | }
|
24 | }
|
25 | _a = asyncIterableMixin;
|
26 | AsyncIterableTransform[_a] = false;
|
27 | return AsyncIterableTransform;
|
28 | })();
|
29 | export { AsyncIterableTransform };
|
30 | export function asAsyncIterable(options = {}) {
|
31 | return new AsyncIterableTransform(options);
|
32 | }
|
33 |
|
34 |
|