arrow-fx-coroutines / arrow.fx.coroutines.stream / Stream / through

through

fun <B> through(pipe: Pipe<O, B>): Stream<B>

Transforms this stream using the given Pipe.

fun <O2, B> through(s2: Stream<O2>, pipe2: Pipe2<O, O2, B>): Stream<B>

Transforms this stream and s2 using the given Pipe2.