MpscReceiver<T> class final

Single consumer for MPSC channels with efficient receive operations.

Receives messages from multiple producers in FIFO order. Designed for single-consumer scenarios with good performance.

Key Features

• Single consumer: Optimized for one consumer, multiple producers
• FIFO ordering: Messages received in first-in, first-out order
• Batching support: Extensions available for bulk operations
• Stream integration: Supports async iteration patterns

Usage Guidelines

• Single consumer only: Only one thread should use this receiver
• Single-subscription stream: stream can only be called once
• Graceful shutdown: Monitor isDisconnected for end-of-data detection
• Error handling: Check RecvResult for different completion states

Example - Event processing loop:

final (eventTx, eventRx) = Mpsc.unbounded<Event>();

// Event processing with different patterns
class EventProcessor {
  Future<void> processEvents() async {
    // Pattern 1: Stream-based (recommended)
    await for (final event in eventRx.stream()) {
      await handleEvent(event);
    }

    // Pattern 2: Manual loop with error handling
    while (true) {
      switch (await eventRx.recv()) {
        case RecvOk(value: final event):
          await handleEvent(event);
        case RecvErrorDisconnected():
          print('All producers finished');
          return;
        case RecvErrorTimeout():
          print('Timeout waiting for events');
          continue;
      }
    }
  }
}

Example - Batch processing:

// Use drain extensions for efficient batch processing
final batch = <LogEntry>[];
await eventRx.drainInto(batch, maxItems: 100);
if (batch.isNotEmpty) {
  await processBatch(batch);
}