Class: ProceduralConnectorTurn<TState, TBus, TSubject>

Makaio Framework

---

Makaio Framework / ai-adapters-core / ProceduralConnectorTurn

Class: ProceduralConnectorTurn<TState, TBus, TSubject>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:60

Base turn implementation for procedural adapters (Gemini, OpenAI, Copilot).

These adapters share an abort+restart pattern rather than true pause/resume. This class extracts the common state machine, lifecycle methods, and message handle delegation that was duplicated across all three.

Subclasses only need to add adapter-specific behavior:

• Gemini: AbortController for SDK cancellation
• OpenAI: AbortController for SDK cancellation
• Copilot: SDK event handling (handleSdkEvent)

Extends

• BaseConnectorTurn<TState>

Type Parameters

TState

TState extends string = ProceduralTurnState

Turn state type (defaults to ProceduralTurnState)

TBus

TBus extends ScopedBus<string> = ScopedBus<string>

Scoped bus type for the adapter

TSubject

TSubject extends ScopedSubjectDefinition = ScopedSubjectDefinition

Subject definition type for emit calls

Constructors

Constructor

new ProceduralConnectorTurn<TState, TBus, TSubject>(config, initialState): ProceduralConnectorTurn<TState, TBus, TSubject>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:71

Parameters

config

ProceduralTurnConfig<TBus, TSubject>

initialState

TState

Returns

ProceduralConnectorTurn<TState, TBus, TSubject>

Overrides

BaseConnectorTurn.constructor

Properties

aborted

protected aborted: boolean = false

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:69

---

activeMessageHandle

protected activeMessageHandle: MessageHandle

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:65

Active message handle for this turn. Subclasses must provide this handle for message lifecycle management.

Overrides

BaseConnectorTurn.activeMessageHandle

---

adapterId

protected readonly adapterId: string

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:31

Inherited from

BaseConnectorTurn.adapterId

---

adapterName

protected readonly adapterName: string

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:32

Inherited from

BaseConnectorTurn.adapterName

---

agentId

protected readonly agentId: string

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:67

---

bus

protected readonly bus: ScopedBus<string>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:30

Inherited from

BaseConnectorTurn.bus

---

connectorBus

protected readonly connectorBus: TBus

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:66

---

state

protected state: TState

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:29

Inherited from

BaseConnectorTurn.state

---

stateChangedCallback?

protected optional stateChangedCallback?: (oldState, newState) => void | Promise<void>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:33

Parameters

oldState

TState

newState

TState

Returns

void | Promise<void>

Inherited from

BaseConnectorTurn.stateChangedCallback

---

turnSubjects

protected readonly turnSubjects: TurnSubjects<TSubject>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:68

Methods

canAcceptImmediate()

canAcceptImmediate(): boolean

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:192

Check if turn can accept immediate message. True if turn is active (not finished, not aborted).

Returns

boolean

True if turn can accept an immediate message

---

emitStateChange()

protected emitStateChange(oldState, newState): Promise<void>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:84

Emit state change using adapter-provided turn subjects.

Parameters

oldState

TState

Previous state before transition

newState

TState

New state after transition

Returns

Promise<void>

Overrides

BaseConnectorTurn.emitStateChange

---

getMessageHandle()

getMessageHandle(): MessageHandle

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:111

Get the message handle for this turn.

Returns

MessageHandle

The message handle for this turn

Inherited from

BaseConnectorTurn.getMessageHandle

---

getState()

getState(): TState

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:103

Get current turn state.

Returns

TState

Current turn state

Inherited from

BaseConnectorTurn.getState

---

isCompleted()

isCompleted(): boolean

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:183

Check if turn is completed.

Returns

boolean

True if turn has finished

---

isPaused()

isPaused(): boolean

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:175

Check if turn was aborted.

Returns

boolean

True if turn was aborted

Overrides

BaseConnectorTurn.isPaused

---

markAcknowledged()

markAcknowledged(): void

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:118

Mark message handle as acknowledged.

Returns

void

Inherited from

BaseConnectorTurn.markAcknowledged

---

markCompleted()

markCompleted(result): void

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:126

Mark message handle as completed.

Parameters

result

The completion result with outcome and optional result/error

error?

unknown

outcome

string

result?

unknown

Returns

void

Inherited from

BaseConnectorTurn.markCompleted

---

markStepFinished()

markStepFinished(): Promise<void>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:132

Transition to step_finished (called after content block completes).

Returns

Promise<void>

---

markStepStarted()

markStepStarted(): Promise<void>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:123

Transition to step_started (called when first content arrives). Allows turn_started to step_started AND step_finished to step_started (for tool recursion).

Returns

Promise<void>

---

markTurnFinished()

markTurnFinished(): Promise<void>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:141

Mark turn as finished.

Returns

Promise<void>

---

onStateChanged()

onStateChanged(cb): void

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:69

Register callback for state changes.

Parameters

cb

(oldState, newState) => void | Promise<void>

Callback to invoke on state transitions

Returns

void

Inherited from

BaseConnectorTurn.onStateChanged

---

pause()

pause(): Promise<PauseResult<TState>>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:151

Pause (abort) at next opportunity. Procedural adapters don’t support true pause - caller creates a new turn with merged content instead.

Returns

Promise<PauseResult<TState>>

Pause result indicating turn state

Overrides

BaseConnectorTurn.pause

---

resume()

resume(_message?): Promise<void>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:167

Resume is not supported for procedural adapters - caller creates new turn.

Parameters

_message?

unknown

Unused

Returns

Promise<void>

Throws

Error always

Overrides

BaseConnectorTurn.resume

---

start()

start(): Promise<void>

Defined in: ../../../adapters/core/src/connector/procedural-connector-turn.ts:114

Start the turn.

Returns

Promise<void>

---

transitionTo()

protected transitionTo(newState): Promise<void>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:81

Transition to new state and notify listeners. Template method for shared state transition pattern.

NOTE: Subclasses should use their typed namespace subjects for emission. This is a template - concrete implementation in adapter-specific Turn classes.

Parameters

newState

TState

New state to transition to

Returns

Promise<void>

Inherited from

BaseConnectorTurn.transitionTo