You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Crossing async boundaries is not free, so when this module is passed
synchronous pipeline stages, do not wrap them in async generators
to keep them synchronous.
BREAKING CHANGE: when the entire pipeline is synchronous, the return value will now be synchronous
Based on this definition of streaming iterables <https://gist.github.com/alanshaw/591dc7dd54e4f99338a347ef568d6ee9>.
25
34
26
35
Almost identical to the [`pipeline`](https://github.com/bustle/streaming-iterables#pipeline) function from the [`streaming-iterables`](https://www.npmjs.com/package/streaming-iterables) module except that it supports duplex streams *and* will automatically wrap a "source" as the first param in a function.
@@ -65,9 +74,9 @@ Note:
65
74
-`firstFn` may be a `Function` or an `Iterable`
66
75
-`firstFn` or any of `fns` may be a [duplex object](https://gist.github.com/alanshaw/591dc7dd54e4f99338a347ef568d6ee9#duplex-it) (an object with a `sink` and `source`).
67
76
68
-
## Contribute
77
+
## API Docs
69
78
70
-
Feel free to dive in! [Open an issue](https://github.com/alanshaw/it-pipe/issues/new) or submit PRs.
0 commit comments