ToEitherStreamExtension<R> extension

Provide toEitherStream extension on Stream.

on

• Stream<R>

Methods

toEitherStream<L>(ErrorMapper<L> errorMapper) → Stream<Either<L, R>>

Transform data events to Rights and error events to Lefts.