IsolateWorkerWrapper<A, S> constructor

IsolateWorkerWrapper<A, S>(EventReceiver _eventReceiver, IsolateWorkerKiller _onClose)

Implementation

IsolateWorkerWrapper(
  this._eventReceiver,
  this._onClose,
) {
  _eventReceiverSubscription = _controller.stream
    .where((event) => event is WorkerEvent)
    .cast<WorkerEvent>()
    .listen((event) {
      if (_workerId != null) {
        _eventReceiver(event.withId(_workerId!));
      } else {
        _unsentEvents.add(event);
      }
    });
}