Skip to main content

timeout

graphrefly_operators::temporal

Function timeout 

Source 
pub fn timeout(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    ms: u64,
    error_handle: HandleId,
) -> NodeId
Expand description

Errors if no upstream DATA arrives within ms milliseconds after subscribe or after the previous DATA. Each DATA resets the timer.

On timeout: retains error_handle and emits ERROR with it. On upstream COMPLETE: cancels timer, forwards complete. On upstream ERROR: cancels timer, forwards error.