subscribeStream method

FieldSubscription<T> subscribeStream(
  1. void onData(
    1. T? event
    ), {
  2. Function? onError,
  3. void onDone()?,
  4. bool cancelOnError = false,
  5. bool current = true,
})

Implementation

FieldSubscription<T> subscribeStream(void onData(T? event),
    {Function? onError,
    void onDone()?,
    bool cancelOnError = false,
    bool current = true}) {
  // ignore: cancel_subscriptions
  final subscription = _stream.stream.listen(
    onData,
  );

  if (value != null && current) {
    onData(value);
  }

  return _addSub<T>(
    subscription,
    onError: onError,
    onDone: onDone,
    cancelOnError: cancelOnError,
  );
}