|
|
|
@ -189,6 +189,7 @@ where |
|
|
|
pub async fn bind(self) -> anyhow::Result<(Server<F>, ServerHandle)> {
|
|
|
|
let listener = TcpListener::bind("localhost:0").await.context("binding")?;
|
|
|
|
let address = listener.local_addr().context("getting local address")?;
|
|
|
|
info!("Server listening on {}", address);
|
|
|
|
|
|
|
|
let (shutdown_tx, shutdown_rx) = oneshot::channel();
|
|
|
|
let (handler_shutdown_tx, handler_shutdown_rx) = watch::channel(());
|
|
|
|
|