latest<T> static method

MpscChannel<T> latest<T>({
  1. String? metricsId,
})

Implementation

static MpscChannel<T> latest<T>({String? metricsId}) {
  final buf = LatestOnlyBuffer<T>();
  final core = StandardChannelCore<T>(
    buf,
    allowMultiSenders: true,
    allowMultiReceivers: false,
    metricsId: metricsId,
  );
  final tx = core.attachSender((c) =>
      MpscSender<T>._(c.id, c.createRemotePort(), metricsId: c.metricsId));
  final rx = core.attachReceiver((c) =>
      MpscReceiver<T>._(c.id, c.createRemotePort(), metricsId: c.metricsId));
  return (tx, rx);
}