doOnData<ENV, A> function

ReaderStream<ENV, A> Function(ReaderStream<ENV, A> ) doOnData<ENV, A>(
  1. ReaderIO<ENV, void> f(
    1. A
    )
)

Implementation

ReaderStream<ENV, A> Function(ReaderStream<ENV, A>) doOnData<ENV, A>(
  RIO.ReaderIO<ENV, void> Function(A) f,
) =>
    (ra) => (r) => ra(r).doOnData((a) => f(a)(r)());