Module sink 

Streaming Sink API.

A Sink is the consumption endpoint of a streaming pipeline. It receives records from a Source and provides them to subscribers.

Modes

• Single subscriber (SPSC): Optimal performance, subscriber gets all records
• Broadcast: Multiple subscribers, each gets a copy of all records

Usage

use laminar_core::streaming;

let (source, sink) = streaming::create::<MyEvent>(1024);

// Single subscriber
let subscription = sink.subscribe();

// Or broadcast to multiple subscribers
let sub1 = sink.subscribe();
let sub2 = sink.subscribe();

Structs

Sink

A streaming data sink.

Enums

SinkMode

Sink mode indicator.