lift<I, O> static method

Conveyor<From<I>, O> lift<I, O>(
  1. Function1<I, O> f
)

Implementation

static Conveyor<From<I>, O> lift<I, O>(Function1<I, O> f) => consume<I, O>((i) => produce(f(i))).repeatUntilExhausted();