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 sees a consistent snapshot of currently attached consumers and queued elements, but it is not run while Datum’s internal hub lock is held.