StreamSubscriptionUnit<T>.zone constructor

StreamSubscriptionUnit<T>.zone(
  1. Zone zone,
  2. StreamLazyMixin<T> _source,
  3. void onData(
    1. T event
    )?, {
  4. Function? onError,
  5. void onDone()?,
  6. bool? cancelOnError,
})

Implementation

StreamSubscriptionUnit.zone(
    this.zone, this._source, void Function(T event)? onData,
    {Function? onError, void Function()? onDone, bool? cancelOnError})
    : _cancelOnError = cancelOnError ?? false,
      _onData = onDataHandle(zone, onData),
      _onDone = onDoneHandler(zone, onDone),
      _onError = onErrorHandle(zone, onError);