NapiCallbackStream<T> constructor

NapiCallbackStream<T>({
  1. required Future<CallbackStreamItem<T>> next()?,
  2. required Future<void> close()?,
  3. ResourceOperation? operation,
})

Implementation

NapiCallbackStream({
  required this._next,
  required this._close,
  ResourceOperation? operation,
}) : _operation = operation {
  _controller = StreamController<T>(
    sync: true,
    onListen: _pull,
    onResume: _pull,
    onCancel: _cancelSubscription,
  );
  operation?.attachStream(this, _cancelStream);
  if (operation != null) _finalizer.attach(this, operation, detach: this);
}