-
Notifications
You must be signed in to change notification settings - Fork 74
/
Copy pathIx.ts
38 lines (34 loc) · 1.65 KB
/
Ix.ts
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
30
31
32
33
34
35
36
37
38
import { AbortError } from './aborterror.js';
import { IterableX } from './iterable/iterablex.js';
import { observable } from './observer.js';
import { AsyncIterableX, AsyncSink } from './asynciterable/asynciterablex.js';
import { GroupedIterable as ImportedGroupedIterable } from './iterable/operators/groupby.js';
import { GroupedAsyncIterable as ImportedGroupedAsyncIterable } from './asynciterable/operators/groupby.js';
export { OrderedIterableX as OrderedIterable } from './iterable/operators/orderby.js';
export { OrderedIterableBaseX as OrderedIterableBase } from './iterable/operators/orderby.js';
export { OrderedAsyncIterableX as OrderedAsyncIterable } from './asynciterable/operators/orderby.js';
export { OrderedAsyncIterableBaseX as OrderedAsyncIterableBase } from './asynciterable/operators/orderby.js';
export { observable as symbolObservable };
export { AbortError, AsyncSink, IterableX as Iterable, AsyncIterableX as AsyncIterable };
// Also export default to accommodate quirks of node's `--experimental-modules` mode
/** @ignore */
export default {
AbortError,
AsyncSink,
Iterable: IterableX,
AsyncIterable: AsyncIterableX,
// prettier-ignore
'symbolObservable': observable
};
/** @ignore */
export type GroupedIterable<TKey, TValue> = ImportedGroupedIterable<TKey, TValue>;
/** @ignore */
export type GroupedAsyncIterable<TKey, TValue> = ImportedGroupedAsyncIterable<TKey, TValue>;
declare global {
interface AsyncIterable<T> {
[Symbol.asyncIterator](signal?: AbortSignal): AsyncIterator<T>;
}
interface AsyncIterableIterator<T> extends AsyncIterator<T> {
[Symbol.asyncIterator](signal?: AbortSignal): AsyncIterableIterator<T>;
}
}