-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.ts
62 lines (62 loc) · 2.62 KB
/
index.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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
import { andIgnoreError } from "./andIgnoreError";
import { sflow } from "./sflow";
export { default as TextDecoderStream } from "polyfill-text-decoder-stream";
export { default as TextEncoderStream } from "polyfill-text-encoder-stream";
export { cacheLists } from "./cacheLists";
export { cacheSkips } from "./cacheSkips";
export { cacheTails } from "./cacheTails";
export { chunkBys } from "./chunkBys";
export { chunkIfs } from "./chunkIfs";
export { chunkIntervals, chunkIntervals as intervals } from "./chunkIntervals";
export { chunks as buffers, chunks } from "./chunks";
export { chunkTransforms } from "./chunkTransforms";
export { concats, concatStream } from "./concats";
export { confluences } from "./confluences";
export { debounces } from "./debounces";
export { distributeBys as distributesBy } from "./distributeBys";
export { filters } from "./filters";
export { flatMaps } from "./flatMaps";
export { flats } from "./flats";
export type { FlowSource } from "./FlowSource";
export { forEachs } from "./forEachs";
export { sfT, sfTemplate } from "./sfTemplate";
// export { fromReadable, fromStdio, fromWritable } from "./fromNodeStream";
export { bys } from "./bys";
export { lines } from "./lines";
export { logs } from "./logs";
export { mapAddFields } from "./mapAddFields";
export { maps } from "./maps";
export { mergeAscends, mergeDescends } from "./mergeAscends";
export { merges as joins, merges } from "./merges";
export { mergeStream } from "./mergeStream";
export {
mergeStreamsBy,
mergeStreamsByAscend,
mergeStreamsByDescend
} from "./mergeStreamsBy";
export { nil, nils } from "./nils";
export { pageFlow } from "./pageFlow";
export { pageStream } from "./pageStream";
export { peeks } from "./peeks";
export { pMaps } from "./pMaps";
export { portals } from "./portals";
export { rangeFlow, rangeStream } from "./rangeStream";
export { reduces } from "./reduces";
export { sflow as sf, sflow as sflow, sflow as snoflow } from "./sflow";
export type { sflowType } from "./sflow";
export { skips } from "./skips";
export { slices } from "./slices";
export { streamAsyncIterator } from "./streamAsyncIterator";
export { matchAlls, matchs, replaceAlls, replaces } from "./strings";
export { svector as sv, svector } from "./svector";
export { tails } from "./tails";
export { tees } from "./tees";
export { terminates as aborts } from "./terminates";
export { throttles } from "./throttles";
export { throughs } from "./throughs";
export { uniqBys, uniqs } from "./uniqs";
export { unpromises } from "./unpromises";
export type { Unwinded } from "./Unwinded";
export { unwinds } from "./unwinds";
export { andIgnoreError };
export default sflow;