Function handleTaskServiceStreamEndForTest

src/node/services/taskService.test.ts:11614–11623

(
    taskService: TaskService,
    event: StreamEndEvent
  )

  }

  async function handleTaskServiceStreamEndForTest(
    taskService: TaskService,
    event: StreamEndEvent
  ): Promise<void> {
    await (
      taskService as unknown as {
        handleStreamEnd: (streamEndEvent: StreamEndEvent) => Promise<void>;
      }
    ).handleStreamEnd(event);
  }

  async function flushTerminalAttentionDrains(taskService: TaskService): Promise<void> {
    // Terminal wake-ups are delivered by an async drain; await any in-flight drains, then await