From 70cf56737328d8ec9f6689b19843369ac529ab0e Mon Sep 17 00:00:00 2001 From: ptaylor Date: Thu, 9 Sep 2021 12:00:25 -0500 Subject: [PATCH] fix: add static Iterable.as and AsyncIterable.as --- src/Ix.node.ts | 311 +++++++++++++++++++----------------- src/add/asynciterable/as.ts | 12 ++ src/add/iterable/as.ts | 12 ++ 3 files changed, 185 insertions(+), 150 deletions(-) create mode 100644 src/add/asynciterable/as.ts create mode 100644 src/add/iterable/as.ts diff --git a/src/Ix.node.ts b/src/Ix.node.ts index a3df3206..c7206b6f 100644 --- a/src/Ix.node.ts +++ b/src/Ix.node.ts @@ -5,189 +5,200 @@ export { AsyncIterableReadable } from './asynciterable/tonodestream'; export { asAsyncIterable, AsyncIterableTransform } from './asynciterable/asasynciterable'; export { fromNodeStream, ReadableStreamAsyncIterable } from './asynciterable/fromnodestream'; -import './add/asynciterable-operators/skipwhile'; -import './add/asynciterable-operators/toset'; -import './add/asynciterable-operators/reverse'; -import './add/asynciterable-operators/min'; -import './add/asynciterable-operators/find'; -import './add/asynciterable-operators/reduceright'; -import './add/asynciterable-operators/tap'; -import './add/asynciterable-operators/union'; -import './add/asynciterable-operators/memoize'; -import './add/asynciterable-operators/finalize'; -import './add/asynciterable-operators/publish'; -import './add/asynciterable-operators/minby'; -import './add/asynciterable-operators/skiplast'; +import './add/asynciterable-operators/average'; +import './add/asynciterable-operators/batch'; +import './add/asynciterable-operators/buffer'; +import './add/asynciterable-operators/catcherror'; +import './add/asynciterable-operators/combinelatest'; +import './add/asynciterable-operators/concatall'; +import './add/asynciterable-operators/concat'; +import './add/asynciterable-operators/count'; +import './add/asynciterable-operators/debounce'; import './add/asynciterable-operators/defaultifempty'; -import './add/asynciterable-operators/intersect'; -import './add/asynciterable-operators/sum'; -import './add/asynciterable-operators/tomap'; -import './add/asynciterable-operators/share'; +import './add/asynciterable-operators/delayeach'; +import './add/asynciterable-operators/delay'; +import './add/asynciterable-operators/distinct'; +import './add/asynciterable-operators/distinctuntilchanged'; +import './add/asynciterable-operators/dowhile'; +import './add/asynciterable-operators/elementat'; +import './add/asynciterable-operators/endwith'; +import './add/asynciterable-operators/every'; +import './add/asynciterable-operators/except'; +import './add/asynciterable-operators/expand'; +import './add/asynciterable-operators/filter'; +import './add/asynciterable-operators/finalize'; +import './add/asynciterable-operators/findindex'; +import './add/asynciterable-operators/find'; +import './add/asynciterable-operators/first'; import './add/asynciterable-operators/flatmap'; -import './add/asynciterable-operators/reduce'; -import './add/asynciterable-operators/takelast'; -import './add/asynciterable-operators/pluck'; -import './add/asynciterable-operators/startwith'; -import './add/asynciterable-operators/includes'; -import './add/asynciterable-operators/orderby'; -import './add/asynciterable-operators/toarray'; -import './add/asynciterable-operators/isempty'; -import './add/asynciterable-operators/scanright'; -import './add/asynciterable-operators/groupjoin'; -import './add/asynciterable-operators/some'; -import './add/asynciterable-operators/forkjoin'; -import './add/asynciterable-operators/pairwise'; -import './add/asynciterable-operators/skip'; -import './add/asynciterable-operators/takewhile'; import './add/asynciterable-operators/flat'; -import './add/asynciterable-operators/first'; -import './add/asynciterable-operators/innerjoin'; +import './add/asynciterable-operators/forkjoin'; +import './add/asynciterable-operators/groupby'; +import './add/asynciterable-operators/groupjoin'; import './add/asynciterable-operators/ignoreelements'; -import './add/asynciterable-operators/retry'; -import './add/asynciterable-operators/combinelatest'; -import './add/asynciterable-operators/average'; +import './add/asynciterable-operators/includes'; +import './add/asynciterable-operators/innerjoin'; +import './add/asynciterable-operators/intersect'; +import './add/asynciterable-operators/isempty'; +import './add/asynciterable-operators/last'; +import './add/asynciterable-operators/map'; import './add/asynciterable-operators/maxby'; -import './add/asynciterable-operators/zip'; -import './add/asynciterable-operators/merge'; -import './add/asynciterable-operators/except'; -import './add/asynciterable-operators/skipuntil'; -import './add/asynciterable-operators/tonodestream'; import './add/asynciterable-operators/max'; -import './add/asynciterable-operators/takeuntil'; -import './add/asynciterable-operators/buffer'; -import './add/asynciterable-operators/filter'; +import './add/asynciterable-operators/memoize'; +import './add/asynciterable-operators/mergeall'; +import './add/asynciterable-operators/merge'; +import './add/asynciterable-operators/minby'; +import './add/asynciterable-operators/min'; import './add/asynciterable-operators/onerrorresumenext'; -import './add/asynciterable-operators/slice'; -import './add/asynciterable-operators/todomstream'; -import './add/asynciterable-operators/map'; +import './add/asynciterable-operators/orderby'; +import './add/asynciterable-operators/pairwise'; +import './add/asynciterable-operators/pluck'; +import './add/asynciterable-operators/publish'; +import './add/asynciterable-operators/reduceright'; +import './add/asynciterable-operators/reduce'; +import './add/asynciterable-operators/repeat'; +import './add/asynciterable-operators/retry'; +import './add/asynciterable-operators/reverse'; +import './add/asynciterable-operators/scanright'; import './add/asynciterable-operators/scan'; -import './add/asynciterable-operators/concatall'; import './add/asynciterable-operators/sequenceequal'; -import './add/asynciterable-operators/distinctuntilchanged'; -import './add/asynciterable-operators/repeat'; -import './add/asynciterable-operators/every'; -import './add/asynciterable-operators/expand'; -import './add/asynciterable-operators/batch'; -import './add/asynciterable-operators/endwith'; -import './add/asynciterable-operators/take'; -import './add/asynciterable-operators/last'; -import './add/asynciterable-operators/mergeall'; -import './add/asynciterable-operators/dowhile'; +import './add/asynciterable-operators/share'; import './add/asynciterable-operators/single'; -import './add/asynciterable-operators/catcherror'; -import './add/asynciterable-operators/findindex'; -import './add/asynciterable-operators/distinct'; -import './add/asynciterable-operators/elementat'; -import './add/asynciterable-operators/concat'; -import './add/asynciterable-operators/toobservable'; -import './add/asynciterable-operators/groupby'; -import './add/asynciterable-operators/debounce'; +import './add/asynciterable-operators/skiplast'; +import './add/asynciterable-operators/skip'; +import './add/asynciterable-operators/skipuntil'; +import './add/asynciterable-operators/skipwhile'; +import './add/asynciterable-operators/slice'; +import './add/asynciterable-operators/some'; +import './add/asynciterable-operators/startwith'; +import './add/asynciterable-operators/sum'; +import './add/asynciterable-operators/takelast'; +import './add/asynciterable-operators/take'; +import './add/asynciterable-operators/takeuntil'; +import './add/asynciterable-operators/takewhile'; +import './add/asynciterable-operators/tap'; import './add/asynciterable-operators/throttle'; -import './add/asynciterable-operators/count'; -import './add/iterable/range'; -import './add/iterable/throwerror'; +import './add/asynciterable-operators/toarray'; +import './add/asynciterable-operators/todomstream'; +import './add/asynciterable-operators/tomap'; +import './add/asynciterable-operators/tonodestream'; +import './add/asynciterable-operators/toobservable'; +import './add/asynciterable-operators/toset'; +import './add/asynciterable-operators/union'; +import './add/asynciterable-operators/withlatestfrom'; +import './add/asynciterable-operators/zip'; +import './add/iterable/as'; import './add/iterable/catchall'; -import './add/iterable/zip'; -import './add/iterable/onerrorresumenext'; +import './add/iterable/catcherror'; +import './add/iterable/concat'; import './add/iterable/create'; -import './add/iterable/repeat'; import './add/iterable/defer'; import './add/iterable/empty'; -import './add/iterable/catcherror'; -import './add/iterable/concat'; +import './add/iterable/from'; import './add/iterable/generate'; import './add/iterable/iif'; +import './add/iterable/of'; +import './add/iterable/onerrorresumenext'; +import './add/iterable/range'; +import './add/iterable/repeat'; +import './add/iterable/throwerror'; import './add/iterable/while'; -import './add/iterable-operators/skipwhile'; -import './add/iterable-operators/toset'; -import './add/iterable-operators/reverse'; -import './add/iterable-operators/min'; -import './add/iterable-operators/find'; -import './add/iterable-operators/reduceright'; -import './add/iterable-operators/tap'; -import './add/iterable-operators/union'; -import './add/iterable-operators/memoize'; -import './add/iterable-operators/finalize'; -import './add/iterable-operators/publish'; -import './add/iterable-operators/minby'; -import './add/iterable-operators/skiplast'; +import './add/iterable/zip'; +import './add/iterable-operators/average'; +import './add/iterable-operators/buffer'; +import './add/iterable-operators/catcherror'; +import './add/iterable-operators/concatall'; +import './add/iterable-operators/concat'; +import './add/iterable-operators/count'; import './add/iterable-operators/defaultifempty'; -import './add/iterable-operators/intersect'; -import './add/iterable-operators/sum'; -import './add/iterable-operators/tomap'; -import './add/iterable-operators/share'; +import './add/iterable-operators/distinct'; +import './add/iterable-operators/distinctuntilchanged'; +import './add/iterable-operators/dowhile'; +import './add/iterable-operators/elementat'; +import './add/iterable-operators/endwith'; +import './add/iterable-operators/every'; +import './add/iterable-operators/except'; +import './add/iterable-operators/expand'; +import './add/iterable-operators/filter'; +import './add/iterable-operators/finalize'; +import './add/iterable-operators/findindex'; +import './add/iterable-operators/find'; +import './add/iterable-operators/first'; import './add/iterable-operators/flatmap'; -import './add/iterable-operators/reduce'; -import './add/iterable-operators/takelast'; -import './add/iterable-operators/pluck'; -import './add/iterable-operators/startwith'; -import './add/iterable-operators/includes'; -import './add/iterable-operators/orderby'; -import './add/iterable-operators/toarray'; -import './add/iterable-operators/isempty'; -import './add/iterable-operators/scanright'; -import './add/iterable-operators/groupjoin'; -import './add/iterable-operators/some'; -import './add/iterable-operators/pairwise'; -import './add/iterable-operators/skip'; -import './add/iterable-operators/takewhile'; import './add/iterable-operators/flat'; -import './add/iterable-operators/first'; -import './add/iterable-operators/innerjoin'; +import './add/iterable-operators/groupby'; +import './add/iterable-operators/groupjoin'; import './add/iterable-operators/ignoreelements'; -import './add/iterable-operators/retry'; -import './add/iterable-operators/average'; +import './add/iterable-operators/includes'; +import './add/iterable-operators/innerjoin'; +import './add/iterable-operators/intersect'; +import './add/iterable-operators/isempty'; +import './add/iterable-operators/last'; +import './add/iterable-operators/map'; import './add/iterable-operators/maxby'; -import './add/iterable-operators/zip'; -import './add/iterable-operators/except'; -import './add/iterable-operators/tonodestream'; import './add/iterable-operators/max'; -import './add/iterable-operators/buffer'; -import './add/iterable-operators/filter'; +import './add/iterable-operators/memoize'; +import './add/iterable-operators/minby'; +import './add/iterable-operators/min'; import './add/iterable-operators/onerrorresumenext'; -import './add/iterable-operators/slice'; -import './add/iterable-operators/todomstream'; -import './add/iterable-operators/map'; +import './add/iterable-operators/orderby'; +import './add/iterable-operators/pairwise'; +import './add/iterable-operators/pluck'; +import './add/iterable-operators/publish'; +import './add/iterable-operators/reduceright'; +import './add/iterable-operators/reduce'; +import './add/iterable-operators/repeat'; +import './add/iterable-operators/retry'; +import './add/iterable-operators/reverse'; +import './add/iterable-operators/scanright'; import './add/iterable-operators/scan'; -import './add/iterable-operators/concatall'; import './add/iterable-operators/sequenceequal'; -import './add/iterable-operators/distinctuntilchanged'; -import './add/iterable-operators/repeat'; -import './add/iterable-operators/every'; -import './add/iterable-operators/expand'; -import './add/iterable-operators/endwith'; -import './add/iterable-operators/take'; -import './add/iterable-operators/last'; -import './add/iterable-operators/dowhile'; +import './add/iterable-operators/share'; import './add/iterable-operators/single'; -import './add/iterable-operators/catcherror'; -import './add/iterable-operators/findindex'; -import './add/iterable-operators/distinct'; -import './add/iterable-operators/elementat'; -import './add/iterable-operators/concat'; -import './add/iterable-operators/groupby'; -import './add/iterable-operators/count'; -import './add/asynciterable/iif'; -import './add/asynciterable/range'; +import './add/iterable-operators/skiplast'; +import './add/iterable-operators/skip'; +import './add/iterable-operators/skipwhile'; +import './add/iterable-operators/slice'; +import './add/iterable-operators/some'; +import './add/iterable-operators/startwith'; +import './add/iterable-operators/sum'; +import './add/iterable-operators/takelast'; +import './add/iterable-operators/take'; +import './add/iterable-operators/takewhile'; +import './add/iterable-operators/tap'; +import './add/iterable-operators/toarray'; +import './add/iterable-operators/todomstream'; +import './add/iterable-operators/tomap'; +import './add/iterable-operators/tonodestream'; +import './add/iterable-operators/toset'; +import './add/iterable-operators/union'; +import './add/iterable-operators/zip'; +import './add/asynciterable/as'; +import './add/asynciterable/asyncifyerrback'; import './add/asynciterable/asyncify'; -import './add/asynciterable/throwerror'; -import './add/asynciterable/forkjoin'; -import './add/asynciterable/fromnodestream'; -import './add/asynciterable/combinelatest'; import './add/asynciterable/catchall'; -import './add/asynciterable/zip'; -import './add/asynciterable/merge'; -import './add/asynciterable/onerrorresumenext'; +import './add/asynciterable/catcherror'; +import './add/asynciterable/combinelatest'; +import './add/asynciterable/concat'; import './add/asynciterable/create'; +import './add/asynciterable/defer'; +import './add/asynciterable/empty'; +import './add/asynciterable/forkjoin'; import './add/asynciterable/fromdomstream'; +import './add/asynciterable/fromeventpattern'; import './add/asynciterable/fromevent'; +import './add/asynciterable/fromnodestream'; +import './add/asynciterable/from'; +import './add/asynciterable/generatetime'; +import './add/asynciterable/generate'; +import './add/asynciterable/iif'; +import './add/asynciterable/merge'; +import './add/asynciterable/never'; +import './add/asynciterable/of'; +import './add/asynciterable/onerrorresumenext'; import './add/asynciterable/race'; +import './add/asynciterable/range'; import './add/asynciterable/repeat'; -import './add/asynciterable/defer'; -import './add/asynciterable/empty'; -import './add/asynciterable/catcherror'; -import './add/asynciterable/concat'; -import './add/asynciterable/generate'; -import './add/asynciterable/fromeventpattern'; -import './add/asynciterable/asyncifyerrback'; +import './add/asynciterable/throwerror'; import './add/asynciterable/while'; +import './add/asynciterable/zip'; diff --git a/src/add/asynciterable/as.ts b/src/add/asynciterable/as.ts new file mode 100644 index 00000000..195d8601 --- /dev/null +++ b/src/add/asynciterable/as.ts @@ -0,0 +1,12 @@ +import { AsyncIterableX } from '../../asynciterable/asynciterablex'; +import { as as asStatic } from '../../asynciterable/as'; + +/** @nocollapse */ +AsyncIterableX.as = asStatic; + +declare module '../../asynciterable/asynciterablex' { + // eslint-disable-next-line no-shadow + namespace AsyncIterableX { + export let as: typeof asStatic; + } +} diff --git a/src/add/iterable/as.ts b/src/add/iterable/as.ts new file mode 100644 index 00000000..47e52cf2 --- /dev/null +++ b/src/add/iterable/as.ts @@ -0,0 +1,12 @@ +import { IterableX } from '../../iterable/iterablex'; +import { as as asStatic } from '../../iterable/as'; + +/** @nocollapse */ +IterableX.as = asStatic; + +declare module '../../iterable/iterablex' { + // eslint-disable-next-line no-shadow + namespace IterableX { + export let as: typeof asStatic; + } +}