clone method

  1. @override
MpmcReceiver<T> clone()

Implementation

@pragma('vm:prefer-inline')
@override
MpmcReceiver<T> clone() {
  if (_closed) {
    throw StateError('Receiver closed');
  }
  return _core.attachReceiver((c) => MpmcReceiver._(c));
}