doOnListenIO function

ReaderStream<ENV, A> Function<ENV, A>(ReaderStream<ENV, A>) doOnListenIO(IO<void> f)

Implementation

ReaderStream<ENV, A> Function<ENV, A>(ReaderStream<ENV, A>) doOnListenIO(
  I.IO<void> f,
) =>
    <A, ENV>(ra) => (r) => ra(r).doOnListen(f.call);