emitReadResults method

void emitReadResults(
  1. Stream<Either<TFailure, TData>> results
)

Implementation

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