EventNode<T> constructor

EventNode<T>({
  1. T? lastData,
  2. Handler<T>? handler,
})

Implementation

EventNode({
  this.lastData,
  this.handler,
  /*this.onCancel*/
}) {
  _streamControllerSub = _streamController.stream.listen((event) {
    if (handler != null) {
      handler!(event, lastData).then((value) {
        if (!(event.completer?.isCompleted ?? false)) {
          event.completer?.complete(null);
        }
      });
    }

    _streamControllerValue.add(event.data);
  });
}