exhaustMap<ENV, A, B> function

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

Implementation

ReaderStream<ENV, B> Function(ReaderStream<ENV, A>) exhaustMap<ENV, A, B>(
  ReaderStream<ENV, B> Function(A) f,
) =>
    (ra) => (r) => ra(r).exhaustMap((a) => f(a)(r));