PullSubscriber constructor

PullSubscriber(
  1. Pointer<Uint8> _subscriberHandle,
  2. Pointer<Uint8> _handlerHandle,
  3. Pointer<Uint8> _teeHandle,
  4. ReceivePort _receivePort,
  5. String _keyExpr,
  6. ChannelKind _kind, [
  7. bool _retainPayload = false,
])

Internal constructor. Use Session.declarePullSubscriber instead.

Implementation

PullSubscriber(
  this._subscriberHandle,
  this._handlerHandle,
  this._teeHandle,
  this._receivePort,
  this._keyExpr,
  this._kind, [
  // Positional rather than named: `_retainPayload` is private, and this is
  // an internal constructor reached only from Session/Querier.
  // ignore: avoid_positional_boolean_parameters
  this._retainPayload = false,
]) {
  _receivePort.listen(_onWake);
}