Struct PartitionHub 

pub struct PartitionHub;

Implementations

impl PartitionHub

pub fn sink<T: Clone + Send + 'static, F>( partitioner: F, start_after_nr_of_consumers: usize, buffer_size: usize, ) -> Sink<T, PartitionHubConsumerSource<T>>

where F: Fn(&PartitionConsumerInfo, &T) -> isize + Send + Sync + 'static,

Materializes a reusable source whose elements are routed to one selected consumer.

The producer still adapts to the slowest active consumer queue unless callers add their own buffering or dropping stages around the materialized consumer sources.

The partitioner runs while the hub’s internal lock is held, matching Akka’s contract, so it must stay fast and non-blocking.