clone method

  1. @override
MpmcReceiver<T> clone()

Implementation

@pragma('vm:prefer-inline')
@override
MpmcReceiver<T> clone() {
  if (_closed) {
    throw StateError('Receiver closed');
  }
  final local = ChannelRegistry.get(channelId);
  if (local is StandardChannelCore<T>) {
    return local.attachReceiver(
        (c) => MpmcReceiver<T>._(c.id, remotePort, metricsId: c.metricsId));
  }
  return MpmcReceiver<T>._(channelId, remotePort, metricsId: metricsId);
}