bindState<T> method

void bindState<T>(
  1. RxState<T> stateVar,
  2. Stream<T> source
)

Implementation

void bindState<T>(RxState<T> stateVar, Stream<T> source) {
  addWorker(source.listen(
    (data) => stateVar.value = RxData<T>(data),
    onError: (e, st) => stateVar.value = RxError<T>(UnknownFailure(
      e.toString(),
      error: e,
      stackTrace: st,
    )),
  ));
}