Skip to content

Interface: DelegateStream

nekte-protocol


nekte-protocol / client/src / DelegateStream

Interface: DelegateStream

Defined in: nekte-source/packages/client/src/transport.ts:50

A delegate stream with lifecycle control.

Returned by client.delegateStream(). Iterate events to consume SSE events; call cancel() to abort the task server-side.

Example

const stream = client.delegateStream(task);
for await (const event of stream.events) {
if (shouldAbort) await stream.cancel('user requested');
}

Properties

events

readonly events: AsyncGenerator<SseEvent>

Defined in: nekte-source/packages/client/src/transport.ts:52

The async generator yielding SSE events


taskId

readonly taskId: string

Defined in: nekte-source/packages/client/src/transport.ts:56

The task ID being tracked

Methods

cancel()

cancel(reason?): Promise<void>

Defined in: nekte-source/packages/client/src/transport.ts:54

Cancel the task server-side and close the stream

Parameters

reason?

string

Returns

Promise<void>