transformStream<A, B> function

ReaderStream<ENV, B> Function<ENV>(ReaderStream<ENV, A> ) transformStream<A, B>(
  1. Stream<B> f(
    1. Stream<A>
    )
)

Implementation

ReaderStream<ENV, B> Function<ENV>(ReaderStream<ENV, A>) transformStream<A, B>(
  Stream<B> Function(Stream<A>) f,
) =>
    <ENV>(ra) => (r) => ra(r).transform(StreamTransformer.fromBind(f));