Class ConversationStreamingService

Implements

OnDestroy

Index

Constructors

Accessors

Methods

clearRecentCompletion getConnectionStatus getConnectionStatus$ getDiagnosticSnapshot getRecentCompletion getRegisteredCallbackCount getTrackedMessageCount initialize ngOnDestroy registerMessageCallback unregisterMessageCallback

Constructors

constructor

new ConversationStreamingService(
_bootstrap: ConversationsRuntimeBootstrap,
): ConversationStreamingService
Parameters
- _bootstrap: ConversationsRuntimeBootstrap
Returns ConversationStreamingService
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:37

Accessors

completionEvents$

get completionEvents$(): Subject<CompletionEvent>
Pass-through to ConversationsRuntime.Instance.Streaming.completionEvents$.

Returns Subject<CompletionEvent>
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:46

Methods

clearRecentCompletion

clearRecentCompletion(conversationDetailId: string): void
Parameters
- conversationDetailId: string
Returns void
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:88

getConnectionStatus

getConnectionStatus(): StreamingConnectionStatus
Returns StreamingConnectionStatus
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:58

getConnectionStatus$

getConnectionStatus$(): Observable<StreamingConnectionStatus>
Returns Observable<StreamingConnectionStatus>
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:54

getDiagnosticSnapshot

getDiagnosticSnapshot(
    messageId: string,
): {
    callbackCount: number;
    connectionStatus: StreamingConnectionStatus;
    hasCallbacks: boolean;
    recentCompletion:
        | { agentRunId: string; conversationDetailId: string; timestamp: Date }
        | undefined;
}
Parameters
- messageId: string
Returns {
    callbackCount: number;
    connectionStatus: StreamingConnectionStatus;
    hasCallbacks: boolean;
    recentCompletion:
        | { agentRunId: string; conversationDetailId: string; timestamp: Date }
        | undefined;
}
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:92

getRecentCompletion

getRecentCompletion(
conversationDetailId: string,
): { agentRunId: string } | undefined
Parameters
- conversationDetailId: string
Returns { agentRunId: string } | undefined
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:84

ngOnDestroy

ngOnDestroy(): void
Angular OnDestroy hook. We do NOT call the runtime's Streaming.Dispose() here — that would tear down a shared singleton on a per-injector destroy, which could affect other consumers. The runtime is process-scoped; its lifecycle ends with the process, not with any Angular injector.

Returns void
Implementation of OnDestroy.ngOnDestroy
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:104

registerMessageCallback

registerMessageCallback(
conversationDetailId: string,
callback: MessageProgressCallback,
): void
Parameters
- conversationDetailId: string
- callback: MessageProgressCallback
Returns void
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:62

unregisterMessageCallback

unregisterMessageCallback(
conversationDetailId: string,
callback?: MessageProgressCallback,
): void
Parameters
- conversationDetailId: string
- Optionalcallback: MessageProgressCallback
Returns void
- Defined in packages/Angular/Generic/conversations/src/lib/services/conversation-streaming.service.ts:69

Class ConversationStreamingService

Implements

Index

Constructors

Accessors

Methods

Constructors

constructor

Parameters

Returns ConversationStreamingService

Accessors

completionEvents$

Returns Subject<CompletionEvent>

Methods

clearRecentCompletion

Parameters

Returns void

getConnectionStatus

Returns StreamingConnectionStatus

getConnectionStatus$

Returns Observable<StreamingConnectionStatus>

getDiagnosticSnapshot

Parameters

Returns { callbackCount: number; connectionStatus: StreamingConnectionStatus; hasCallbacks: boolean; recentCompletion: | { agentRunId: string; conversationDetailId: string; timestamp: Date } | undefined;}

getRecentCompletion

Parameters

Returns { agentRunId: string } | undefined

getRegisteredCallbackCount

Returns number

getTrackedMessageCount

Returns number

initialize

Returns void

ngOnDestroy

Returns void

registerMessageCallback

Parameters

Returns void

unregisterMessageCallback

Parameters

Returns void

Settings

On This Page

Returns {
callbackCount: number;
connectionStatus: StreamingConnectionStatus;
hasCallbacks: boolean;
recentCompletion:
| { agentRunId: string; conversationDetailId: string; timestamp: Date }
| undefined;
}