Interface: ProcessQueueCallbacks<TExtra>
Makaio Framework / ai-adapters-core / ProcessQueueCallbacks
Interface: ProcessQueueCallbacks<TExtra>
Section titled “Interface: ProcessQueueCallbacks<TExtra>”Defined in: ../../../adapters/core/src/session/process-queue.ts:37
Callbacks for adapter-specific behavior during queue processing.
Type Parameters
Section titled “Type Parameters”TExtra
Section titled “TExtra”TExtra = unknown
Type of adapter-specific extra merge data
Properties
Section titled “Properties”collectMergeExtra?
Section titled “collectMergeExtra?”
optionalcollectMergeExtra?: (currentHandle,enqueuedHandles) =>TExtra
Defined in: ../../../adapters/core/src/session/process-queue.ts:61
Called after merge content is collected from superseded/enqueued messages. Allows adapters to collect additional content (e.g., Gemini’s non-text parts).
If not provided, only text content is collected using extractContent.
Parameters
Section titled “Parameters”currentHandle
Section titled “currentHandle”MessageHandle | undefined
The in-flight message handle being superseded (or undefined)
enqueuedHandles
Section titled “enqueuedHandles”The enqueued handles being merged
Returns
Section titled “Returns”TExtra
Extra merge data to pass through to startNewTurn
extractContent?
Section titled “extractContent?”
optionalextractContent?: (handle) =>string
Defined in: ../../../adapters/core/src/session/process-queue.ts:50
Extract text content from a message handle for merge.
Default: handle.message.message as string
Parameters
Section titled “Parameters”handle
Section titled “handle”The message handle to extract content from
Returns
Section titled “Returns”string
The text content
getCurrentTurn
Section titled “getCurrentTurn”getCurrentTurn: () =>
QueueableTurn|undefined
Defined in: ../../../adapters/core/src/session/process-queue.ts:42
Get the current turn, if any.
Returns
Section titled “Returns”QueueableTurn | undefined
The current turn or undefined
onBeforeImmediateTurn?
Section titled “onBeforeImmediateTurn?”
optionalonBeforeImmediateTurn?: () =>Promise<void>
Defined in: ../../../adapters/core/src/session/process-queue.ts:67
Hook called after merge is collected but before starting the new turn. Used by Claude to create a fresh query instance.
Returns
Section titled “Returns”Promise<void>
startNewTurn
Section titled “startNewTurn”startNewTurn: (
handle,mergedContent?,extra?) =>Promise<void>
Defined in: ../../../adapters/core/src/session/process-queue.ts:75
Start a new turn with the given message and optional merge data.
Parameters
Section titled “Parameters”handle
Section titled “handle”The message handle to process
mergedContent?
Section titled “mergedContent?”string[]
Text content from superseded/merged messages
extra?
Section titled “extra?”TExtra
Adapter-specific extra merge data
Returns
Section titled “Returns”Promise<void>