Skip to main content

continue_via_pool

Function continue_via_pool 

Source
pub async fn continue_via_pool(
    entry: &PoolSessionEntry,
    sid: &str,
    response: String,
    query_id: Option<String>,
    usage: Option<TokenUsage>,
) -> Result<String, PoolError>
Expand description

Reconnect to an existing pool worker via its registry entry and forward a Continue request.

§Arguments

  • entry — the registry entry for the target worker (sock path, etc.).
  • sid — session ID to resume.
  • response — LLM response text.
  • query_id — optional query ID being answered.
  • usage — optional token usage.

§Returns

Ok(json_response) — the stringified feed_result JSON from the worker.

§Errors

Returns Err(PoolError) on UDS connect failure or invalid response.

§Cancel safety

If this future is cancelled mid-await, the PoolClient is dropped and the socket is closed. read_line is not cancel-safe; a partial line would corrupt the buffer. Dropping the client is the correct recovery — the next continue_via_pool call creates a fresh connection.