WebSocket transport for the turn-detector-v1 (cloud) model.
Maintains one inference session against the LiveKit Agent Gateway:
connect → SessionCreate → three concurrent tasks (drain audio, send,
receive) → protobuf encode/decode → stream._resolvePrediction(...) +
EOTInferenceMetrics on the detector.
All outbound messages flow through a single FIFO send channel so control
hooks fired synchronously between two awaited audio frames (e.g.
inferenceStart then inputAudio) reach the wire in call order.
WebSocket transport for the
turn-detector-v1(cloud) model.Maintains one inference session against the LiveKit Agent Gateway: connect →
SessionCreate→ three concurrent tasks (drain audio, send, receive) → protobuf encode/decode →stream._resolvePrediction(...)+EOTInferenceMetricson the detector.All outbound messages flow through a single FIFO send channel so control hooks fired synchronously between two awaited audio frames (e.g.
inferenceStarttheninputAudio) reach the wire in call order.