InterruptConformanceHarness

Opt-in harness: pause and failure must be driven through the real adapter.

import type { InterruptConformanceHarness } from '@threadplane/chat/testing';

Declaration

export interface InterruptConformanceHarness  {
  agent: Agent;
  backendCancellationCount(): number;
  cleanup(): void | Promise<void>;
  deliverLateEvents(): Promise<void>;
  failNextDispatch(): void;
  pause(): Promise<void>;
  pendingBatch(): Array<{
        id: string;
        value: unknown;
    }>;
  requests: InterruptConformanceRequest[];
  restore?: () => Promise<void>;
  resume: unknown;
  startLateDelivery(): Promise<void>;
}

Members

agent

agent: Agent;

backendCancellationCount · overload 1

backendCancellationCount(): number;

Returns

number

cleanup · overload 1

cleanup(): void | Promise<void>;

Returns

void | Promise<void>

deliverLateEvents · overload 1

Release captured native callbacks/events, even after cleanup.

deliverLateEvents(): Promise<void>;

Returns

Promise<void>

failNextDispatch · overload 1

failNextDispatch(): void;

Returns

void

pause · overload 1

pause(): Promise<void>;

Returns

Promise<void>

pendingBatch · overload 1

pendingBatch(): Array<{
        id: string;
        value: unknown;
    }>;

Returns

Array<{ id: string; value: unknown; }>

requests

restore

Optional backend history/store restoration; never synthesizes a local pause.

restore?: () => Promise<void>;

resume

Native decision addressing every interrupt in the fixture batch.

resume: unknown;

startLateDelivery · overload 1

Start a native run and hold its delivery until deliverLateEvents is called.

startLateDelivery(): Promise<void>;

Returns

Promise<void>