Function mz_storage::boundary::tcp_boundary::server::accept
source · [−]async fn accept(
listener: TcpListener,
worker_rx: UnboundedReceiver<WorkerResponse>,
render_requests: UnboundedSender<SourceInstanceRequest>,
storage_workers: usize
) -> Result<()>
Expand description
Accept connections on listener
and listening for data on worker_rx
.