clone method

  1. @override
MpscSender<T> clone()

Implementation

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