SpscReceiver<T> class final

Efficient receiver for SPSC channels.

Provides optimized message receiving for single-consumer scenarios. Designed for good performance and throughput.

Performance Optimizations

• Efficient operations: Optimized communication path
• Memory-friendly design: Minimizes unnecessary overheads
• Single-subscription streams: No overhead from multi-consumer coordination

Usage Guidelines

• Only ONE thread should use this receiver instance
• Use tryRecv for polling in time-critical scenarios
• Use recv for blocking receives when timing is flexible
• Use stream for convenient async iteration (single-use only)
• Monitor isDisconnected for end-of-stream detection

Example - High-frequency consumer:

final (tx, rx) = Spsc.channel<DataPoint>(capacity: 4096);

// Low-latency consumer loop
void consumeData() async {
  while (running) {
    switch (await rx.recv()) {
      case RecvOk(value: final data):
        // Process immediately - no queuing
        await processDataPoint(data);

      case RecvErrorDisconnected():
        print('Producer finished');
        return;

      case RecvErrorEmpty():
        // Impossible with recv() - only from tryRecv()
        break;
    }
  }
}

// Alternative: Stream-based consumption
await for (final data in rx.stream()) {
  await processDataPoint(data);
}