Skip to main content

tap_observer

graphrefly_operators::control

Function tap_observer 

Source 
pub fn tap_observer(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    data_fn_id: Option<FnId>,
    error_fn_id: Option<FnId>,
    complete_fn_id: Option<FnId>,
) -> NodeId
Expand description

Like tap but with lifecycle observer callbacks. Each callback is optional (None = skip that lifecycle event).

  • data_fn_id: called on each DATA via invoke_tap_fn.
  • error_fn_id: called on ERROR via invoke_tap_error_fn.
  • complete_fn_id: called on COMPLETE via invoke_tap_complete_fn.

All messages are forwarded unchanged regardless of callback presence.