Pass subscriber into a stream (or any arguments into any other function).
This utility is mainly here for uses like:
pipe(src, into(sink))
pipe(src, into(sink, conn))
pipe(src, into(restarting(sink)))
but can also be used for argument currying generally.
The arguments to pass to the stream (or other function)
a function that takes another function and calls it with the given args.
Pass subscriber into a stream (or any arguments into any other function).
This utility is mainly here for uses like:
pipe(src, into(sink)),pipe(src, into(sink, conn)),pipe(src, into(restarting(sink))), etc.but can also be used for argument currying generally.