Function sendEvent

apps/sim/lib/workflows/executor/execution-events.ts:489–496

(event: ExecutionEvent)

  const { executionId, workflowId, controller, isStreamClosed, setStreamClosed } = options

  const sendEvent = (event: ExecutionEvent) => {
    if (isStreamClosed()) return
    try {
      controller.enqueue(encodeSSEEvent(event))
    } catch {
      setStreamClosed()
    }
  }

  return createExecutionCallbacks({
    executionId,