Documentation / @agentick/kernel / ExecutionHandleImpl

Class: ExecutionHandleImpl<TResult, TEvent>

Default implementation of ExecutionHandle.

Creates a handle that wraps a result promise and event stream. Uses EventBuffer for dual consumption - multiple iterators can independently consume all events, and late subscribers receive replayed events.

Type Parameters

TResult

TResult

The return type of the procedure

TEvent

TEvent extends TypedEvent = any

The event type for streaming

Implements

ExecutionHandle<TResult, TEvent>

Constructors

Constructor

new ExecutionHandleImpl<TResult, TEvent>(result, events, traceId, abortController?): ExecutionHandleImpl<TResult, TEvent>

Defined in: kernel/src/procedure.ts:319

Parameters

result

Promise<TResult>

events

EventBuffer<TEvent>

traceId

string

abortController?

AbortController

Returns

ExecutionHandleImpl<TResult, TEvent>

Properties

[ExecutionHandleBrand]

readonly [ExecutionHandleBrand]: true

Defined in: kernel/src/procedure.ts:312

Brand identifying this as an ExecutionHandle (not a plain AsyncIterable)

Implementation of

ExecutionHandle.[ExecutionHandleBrand]

events

readonly events: EventBuffer<TEvent>

Defined in: kernel/src/procedure.ts:315

Event buffer for streaming execution events. Supports dual consumption - multiple iterators can independently consume all events. Late subscribers receive replayed events from the start.

API is compatible with EventEmitter: on, once, off, emit, addListener, removeListener. Use on('eventType', handler) to subscribe to specific event types. Use on(handler) or on('*', handler) for wildcard subscription.