emitReadResults method
Implementation
void emitReadResults(Stream<Either<TFailure, TData>> results) {
assert(_readSub == null);
_readSub = results.listen((result) => result.fold(emitReadFailed, emitRead));
}
void emitReadResults(Stream<Either<TFailure, TData>> results) {
assert(_readSub == null);
_readSub = results.listen((result) => result.fold(emitReadFailed, emitRead));
}