Method accept

src/environmentd/tests/sql.rs:102–107

Accepts a new connection. The future resolves once a new connection has arrived at the server and is awaiting a response. The provided oneshot channel should be used to deliver the response.

(&mut self)

    /// is awaiting a response. The provided oneshot channel should be used to
    /// deliver the response.
    async fn accept(&mut self) -> oneshot::Sender<Response> {
        self.conn_rx
            .recv()
            .await
            .expect("server unexpectedly closed channel")
    }
}

#[mz_ore::test(tokio::test(flavor = "multi_thread", worker_threads = 1))]