CoffeeVampir3

import { StreamingWebSocket, CancellationError } from "./streamingWebSocket.ts";

/**
 * Example of client-side streaming inference implementation
 * Following the exact flow described in the specification
 */
async function streamInference(
  socket: StreamingWebSocket,
  onContent: (content: string) => void
): Promise<void> {