Skip to main content

tap

graphrefly_operators::control

Function tap 

Source 
pub fn tap(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    fn_id: FnId,
) -> NodeId
Expand description

Passthrough operator that forwards all DATA unchanged. On each DATA, calls binding.invoke_tap_fn(fn_id, handle) as a side-effect. Forwards COMPLETE and ERROR unchanged.