pub async fn run(
session: AgentSession,
options: RpcOptions,
in_rx: Receiver<String>,
out_tx: Sender<String>,
) -> Result<()>pub async fn run(
session: AgentSession,
options: RpcOptions,
in_rx: Receiver<String>,
out_tx: Sender<String>,
) -> Result<()>