RillTuple2Ops<T1, T2>
extension RillTuple2Ops<T1, T2> on Rill<Record>Provides additional functions on a Rill of a 2 element tuple.
Methods
collectN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> collectN<T3>(Function2<T1, T2, Option<T3>> f) => collect(f.tupled);evalMapN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> evalMapN<T3>(Function2<T1, T2, IO<T3>> f) => evalMap(f.tupled);evalTapN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<(T1, T2)> evalTapN<T3>(Function2<T1, T2, IO<T3>> f) => evalTap(f.tupled);filterN() extension
Rill<Record> filterN(bool Function(T1, T2) f)Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<(T1, T2)> filterN(Function2<T1, T2, bool> f) => filter(f.tupled);filterNotN() extension
Rill<Record> filterNotN(bool Function(T1, T2) f)Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<(T1, T2)> filterNotN(Function2<T1, T2, bool> f) => filterNot(f.tupled);flatMapN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> flatMapN<T3>(Function2<T1, T2, Rill<T3>> f) => flatMap(f.tupled);mapN() extension
Rill<T3> mapN<T3>(T3 Function(T1, T2) f)Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> mapN<T3>(Function2<T1, T2, T3> f) => map(f.tupled);parEvalMapN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> parEvalMapN<T3>(
int maxConcurrent,
Function2<T1, T2, IO<T3>> f,
) => parEvalMap(maxConcurrent, f.tupled);parEvalMapUnboundedN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> parEvalMapUnboundedN<T3>(Function2<T1, T2, IO<T3>> f) => parEvalMapUnbounded(f.tupled);parEvalMapUnorderedN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> parEvalMapUnorderedN<T3>(
int maxConcurrent,
Function2<T1, T2, IO<T3>> f,
) => parEvalMapUnordered(maxConcurrent, f.tupled);parEvalMapUnorderedUnboundedN() extension
Available on Rill<O>, provided by the RillTuple2Ops<T1, T2> extension
Implementation
Rill<T3> parEvalMapUnorderedUnboundedN<T3>(Function2<T1, T2, IO<T3>> f) =>
parEvalMapUnorderedUnbounded(f.tupled);