reader_stream library

Support for doing something awesome.

More dartdocs go here.

Properties

asBroadcastStream → ReaderStream<ENV, A> Function<ENV, A>(ReaderStream<ENV, A> )

final

Functions

apFirst<ENV, B>(ReaderStream<ENV, B> rs1) → ReaderStream<ENV, A> Function<A>(ReaderStream<ENV, A> )

apSecond<ENV, B>(ReaderStream<ENV, B> rs1) → ReaderStream<ENV, B> Function<A>(ReaderStream<ENV, A> )

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

asks<ENV, A>(Reader<ENV, A> f) → ReaderStream<ENV, A>

asksReaderStream<ENV, A>(ReaderStream<ENV, A> f) → ReaderStream<ENV, A>

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

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

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

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

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

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

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

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

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

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

fromReader<ENV, A>(Reader<ENV, Stream<A>> rio) → ReaderStream<ENV, A>

fromReaderIO<ENV, A>(ReaderIO<ENV, A> rio) → ReaderStream<ENV, A>

fromReaderTask<ENV, A>(ReaderTask<ENV, A> rt) → ReaderStream<ENV, A>

ignoreElements<ENV, A>(ReaderStream<ENV, A> ra) → ReaderStream<ENV, Never>

local<ENV1, ENV2>(ENV1 f(ENV2)) → ReaderStream<ENV2, A> Function<A>(ReaderStream<ENV1, A> )

map<A, B>(B f(A)) → ReaderStream<ENV, B> Function<ENV>(ReaderStream<ENV, A> )

startWith<A>(A a) → ReaderStream<ENV, A> Function<ENV>(ReaderStream<ENV, A> )

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

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

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

where<A>(bool predicate(A)) → ReaderStream<ENV, A> Function<ENV>(ReaderStream<ENV, A> )

whereType<T>() → ReaderStream<ENV, T> Function<ENV, A>(ReaderStream<ENV, A> )

Typedefs

ReaderStream<ENV, A> = Stream<A> Function(ENV)