Method receive

crates/opencode-mcp/src/client.rs:948–957

(&self)

        }

        async fn receive(&self) -> Result<Option<JsonRpcMessage>, McpClientError> {
            let next = self.messages.lock().await.pop_front();
            match next {
                Some((delay, message)) => {
                    sleep(delay).await;
                    Ok(message)
                }
                None => Ok(None),
            }
        }

        async fn close(&self) -> Result<(), McpClientError> {
            Ok(())