Function mz_dataflow::tcp_boundary::server::serve

pub async fn serve<A>(
    addr: A, 
    storage_workers: usize
) -> Result<(TcpEventLinkHandle, UnboundedReceiver<SourceInstanceRequest<u64>>, JoinHandle<Result<(), Error>>), Error> where
    A: ToSocketAddrs + Display, 

Start the boundary server listening for connections on addr.

Returns a handle implementing StorageCapture and a join handle to await termination.