MCPcopy Index your code
hub / github.com/coder/mux / emitStreamStart

Function emitStreamStart

src/node/services/sessionTimingService.test.ts:94–117  ·  view source on GitHub ↗
(
    params: {
      workspaceId?: string;
      messageId?: string;
      model?: string;
      startTime?: number;
      historySequence?: number;
      mode?: "exec" | "plan";
      agentId?: string;
      replay?: true;
    } = {}
  )

Source from the content-addressed store, hash-verified

92 });
93
94 function emitStreamStart(
95 params: {
96 workspaceId?: string;
97 messageId?: string;
98 model?: string;
99 startTime?: number;
100 historySequence?: number;
101 mode?: "exec" | "plan";
102 agentId?: string;
103 replay?: true;
104 } = {}
105 ): void {
106 service.handleStreamStart({
107 type: "stream-start",
108 workspaceId: params.workspaceId ?? "test-workspace",
109 messageId: params.messageId ?? "m1",
110 model: params.model ?? "openai:gpt-4o",
111 historySequence: params.historySequence ?? 1,
112 startTime: params.startTime ?? 1_000_000,
113 mode: params.mode ?? "exec",
114 ...(params.agentId != null ? { agentId: params.agentId } : {}),
115 ...(params.replay != null ? { replay: params.replay } : {}),
116 });
117 }
118
119 function emitStreamDelta(
120 params: {

Calls 1

handleStreamStartMethod · 0.65

Tested by

no test coverage detected