ReaderStreamBuilder<ENV, A> class final

Constructors

ReaderStreamBuilder(ReaderStream<ENV, A> _f)

const

Properties

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

apFirst<B>(ReaderStream<ENV, B> second) → ReaderStreamBuilder<ENV, A>

apSecond<B>(ReaderStream<ENV, B> second) → ReaderStreamBuilder<ENV, B>

asBroadcastStream() → ReaderStreamBuilder<ENV, A>

build() → ReaderStream<ENV, A>

concatMap<B>(ReaderStream<ENV, B> f(A)) → ReaderStreamBuilder<ENV, B>

concatMapStream<B>(Stream<B> f(A)) → ReaderStreamBuilder<ENV, B>

doOnData(ReaderIO<ENV, void> f(A)) → ReaderStreamBuilder<ENV, A>

doOnDataIO(IO<void> f(A)) → ReaderStreamBuilder<ENV, A>

doOnListen(ReaderIO<ENV, void> f) → ReaderStreamBuilder<ENV, A>

doOnListenIO(IO<void> f) → ReaderStreamBuilder<ENV, A>

exhaustMap<B>(ReaderStream<ENV, B> f(A)) → ReaderStreamBuilder<ENV, B>

exhaustMapStream<B>(Stream<B> f(A)) → ReaderStreamBuilder<ENV, B>

flatMap<B>(ReaderStream<ENV, B> f(A)) → ReaderStreamBuilder<ENV, B>

flatMapStream<B>(Stream<B> f(A)) → ReaderStreamBuilder<ENV, B>

ignoreElements() → ReaderStreamBuilder<ENV, Never>

local<ENV2>(ENV f(ENV2)) → ReaderStreamBuilder<ENV2, A>

map<B>(B f(A)) → ReaderStreamBuilder<ENV, B>

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

startWith(A a) → ReaderStreamBuilder<ENV, A>

switchMap<B>(ReaderStream<ENV, B> f(A)) → ReaderStreamBuilder<ENV, B>

switchMapStream<B>(Stream<B> f(A)) → ReaderStreamBuilder<ENV, B>

toReader() → ReaderBuilder<ENV, Stream<A>>

toString() → String

A string representation of this object.

inherited

transformStream<B>(Stream<B> f(Stream<A>)) → ReaderStreamBuilder<ENV, B>

where(bool predicate(A)) → ReaderStreamBuilder<ENV, A>

whereType<T>() → ReaderStreamBuilder<ENV, T>

Operators

operator ==(Object other) → bool

The equality operator.

inherited

Static Methods

ask<ENV>() → ReaderStreamBuilder<ENV, ENV>

asks<ENV, ENV2>(ENV2 f(ENV)) → ReaderStreamBuilder<ENV, ENV2>