doOnDataIO<A> function

ReaderStream<ENV, A> Function<ENV>(ReaderStream<ENV, A> ) doOnDataIO<A>(
  1. IO<void> f(
    1. A
    )
)

Implementation

ReaderStream<ENV, A> Function<ENV>(ReaderStream<ENV, A>) doOnDataIO<A>(
  I.IO<void> Function(A) f,
) =>
    <ENV>(ra) => (r) => ra(r).doOnData((a) => f(a)());