apply_backpressure

rust_logic_graph::streaming

Function apply_backpressure 

Source 
pub fn apply_backpressure(
    stream: ValueStream,
    _config: BackpressureConfig,
) -> ValueStream
Expand description

Apply backpressure to a stream Note: This is a placeholder. For full backpressure, use StreamNode with BackpressureConfig