Method execute_streaming

core/src/workflow.rs:374–384

Execute a workflow with real-time streaming events. Identical to [`execute`] but emits [`StreamEvent`]s through `event_tx` at every node boundary. The caller consumes events from the corresponding `mpsc::Receiver` while this future runs (typically in a spawned task). # Arguments `workflow` — the workflow to execute `guardrail_enforcer` — optional PII masking enforcer `event_tx` — sender half of

(
        &self,
        workflow: Workflow,
        guardrail_enforcer: Option<Arc<Enforcer>>,
        event_tx: tokio::sync::mpsc::Sender<crate::stream::StreamEvent>,
        stream_mode: crate::str

    /// If the receiver is dropped (e.g. the caller stops iterating early),
    /// send failures are silently ignored — the workflow still runs to completion.
    pub async fn execute_streaming(
        &self,
        workflow: Workflow,
        guardrail_enforcer: Option<Arc<Enforcer>>,
        event_tx: tokio::sync::mpsc::Sender<crate::stream::StreamEvent>,
        stream_mode: crate::stream::StreamMode,
    ) -> GraphBitResult<WorkflowContext> {
        let context = WorkflowContext::new(workflow.id.clone());
        self.execute_internal(workflow, guardrail_enforcer, Some(event_tx), stream_mode, context)
            .await
    }

    /// Shared execution engine used by both [`execute`] and [`execute_streaming`].
    ///