doOnListen<ENV> function

ReaderStream<ENV, A> Function<A>(ReaderStream<ENV, A>) doOnListen<ENV>(ReaderIO<ENV, void> f)

Implementation

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