arrow-fx-coroutines / arrow.fx.coroutines.stream / Pipe2

Pipe2

typealias ~~Pipe2~~<I, I2, O> = (Stream<I>, Stream<I2>) -> Stream<O> Deprecated: Pipe is deprecated as part of Stream deprecation.

A stream transformation that combines two streams in to a single stream, represented as a function from two streams to a single stream.

Since we cannot define extension functions with multiple subscribers, Pipe2 is not an alias for extension functions but allows more powerful transformations.

Pipe2s are typically applied with the through operation on Stream.

fun <I, I2, O> ~~Pipe2~~(pipe: (Stream<I>, Stream<I2>) -> Stream<O>): Pipe2<I, I2, O> Deprecated: Pipe is deprecated as part of Stream deprecation.