Skip to content
Kuralle

QueuedTurnRunner

Implements

Section titled “Implements”
  • TurnRunner

Constructors

Section titled “Constructors”

Constructor

Section titled “Constructor”
new QueuedTurnRunner(
   inner,
   queue?,
   messageConcurrency?): QueuedTurnRunner;

Parameters

Section titled “Parameters”
Parameter Type Default value

inner

TurnRunner

undefined

queue

TurnQueueLike

...

messageConcurrency

MessageConcurrency

'queue'

Returns

Section titled “Returns”

QueuedTurnRunner

Methods

Section titled “Methods”

concurrency()

Section titled “concurrency()”
concurrency(): MessageConcurrency;

Returns

Section titled “Returns”

MessageConcurrency

deliverSignal()

Section titled “deliverSignal()”
deliverSignal(args): Promise<TurnResult>;

Parameters

Section titled “Parameters”
Parameter Type

args

{ key: ConversationKey; sessionId?: string; signal: SignalDelivery; signal2?: AbortSignal; }

args.key

ConversationKey

args.sessionId?

string

args.signal

SignalDelivery

args.signal2?

AbortSignal

Returns

Section titled “Returns”

Promise<TurnResult>

Implementation of

Section titled “Implementation of”
TurnRunner.deliverSignal

runTurn()

Section titled “runTurn()”
runTurn(args): Promise<TurnResult>;

Parameters

Section titled “Parameters”
Parameter Type

args

{ input: UserContent; key: ConversationKey; selection?: ResolvedSelection; sessionId?: string; signal?: AbortSignal; userId?: string; }

args.input

UserContent

args.key

ConversationKey

args.selection?

ResolvedSelection

args.sessionId?

string

args.signal?

AbortSignal

args.userId?

string

Returns

Section titled “Returns”

Promise<TurnResult>

Implementation of

Section titled “Implementation of”
TurnRunner.runTurn

waitForIdle()

Section titled “waitForIdle()”
waitForIdle(): Promise<void>;

Returns

Section titled “Returns”

Promise<void>