@threadplane/langgraphClassv0.3.4

FakeStreamTransport

In-process AgentTransport that auto-streams a canned assistant reply.

Backs provideFakeAgent(). Unlike MockAgentTransport (passive, driven manually from specs), this transport emits its tokens automatically on stream(), then completes — suitable for offline demos and integration tests.

NOT for production use.

View sourceView Markdown
import { FakeStreamTransport } from '@threadplane/langgraph';

Declaration

export declare class FakeStreamTransport implements AgentTransport  {
  constructor(config?: FakeAgentConfig);
  cancelRun(_threadId: string, _runId: string, _signal: AbortSignal): Promise<void>;
  createQueuedRun(_assistantId: string, threadId: string, payload: unknown, _signal: AbortSignal, options?: LangGraphSubmitOptions): Promise<AgentQueueEntry>;
  getHistory(_threadId: string, _signal: AbortSignal): Promise<ThreadState[]>;
  joinStream(): AsyncIterable<StreamEvent>;
  stream(_assistantId: string, _threadId: string | null, _payload: unknown, signal: AbortSignal, _options?: LangGraphSubmitOptions): AsyncIterable<StreamEvent>;
}

Members

Constructor · overload 1

Constructs a new instance of the FakeStreamTransport class

constructor(config?: FakeAgentConfig);

Parameters

config · optional
FakeAgentConfig

cancelRun · overload 1

cancelRun(_threadId: string, _runId: string, _signal: AbortSignal): Promise<void>;

Parameters

_threadId · required
string
_runId · required
string
_signal · required
AbortSignal

Returns

Promise<void>

createQueuedRun · overload 1

createQueuedRun(_assistantId: string, threadId: string, payload: unknown, _signal: AbortSignal, options?: LangGraphSubmitOptions): Promise<AgentQueueEntry>;

Parameters

_assistantId · required
string
threadId · required
string
payload · required
unknown
_signal · required
AbortSignal
options · optional
LangGraphSubmitOptions

Returns

Promise<AgentQueueEntry>

getHistory · overload 1

getHistory(_threadId: string, _signal: AbortSignal): Promise<ThreadState[]>;

Parameters

_threadId · required
string
_signal · required
AbortSignal

Returns

Promise<ThreadState[]>

joinStream · overload 1

joinStream(): AsyncIterable<StreamEvent>;

Returns

AsyncIterable<StreamEvent>

stream · overload 1

stream(_assistantId: string, _threadId: string | null, _payload: unknown, signal: AbortSignal, _options?: LangGraphSubmitOptions): AsyncIterable<StreamEvent>;

Parameters

_assistantId · required
string
_threadId · required
string | null
_payload · required
unknown
signal · required
AbortSignal
_options · optional
LangGraphSubmitOptions

Returns

AsyncIterable<StreamEvent>