toRx method

Rx<T> toRx(
  1. T initial, {
  2. void onError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
  3. void onDone()?,
  4. bool? cancelOnError,
})

Implementation

Rx<T> toRx(
  T initial, {
  void Function(Object error, StackTrace stackTrace)? onError,
  void Function()? onDone,
  bool? cancelOnError,
}) =>
    Rx<T>.fromStream(
      this,
      initial: initial,
      onError: onError,
      onDone: onDone,
      cancelOnError: cancelOnError,
    );