bounded<T> static method

(SpscSender<T>, SpscReceiver<T>) bounded<T>(
  1. int capacity, {
  2. String? metricsId,
})

Implementation

static (SpscSender<T>, SpscReceiver<T>) bounded<T>(int capacity,
    {String? metricsId}) {
  final core = StandardChannelCore<T>(
    SrswBuffer<T>(capacity),
    allowMultiSenders: false,
    allowMultiReceivers: false,
    metricsId: metricsId,
  );
  final tx = core.attachSender((c) =>
      SpscSender<T>._(c.id, c.createRemotePort(), metricsId: c.metricsId));
  final rx = core.attachReceiver((c) =>
      SpscReceiver<T>._(c.id, c.createRemotePort(), metricsId: c.metricsId));
  return (tx, rx);
}