Function mz_dataflow::tcp_boundary::client::connect
source · [−]pub async fn connect<A>(
addr: A,
workers: usize
) -> Result<(TcpEventLinkClientHandle, JoinHandle<Result<(), Error>>), Error> where
A: ToSocketAddrs + Debug,
Expand description
Connect to a storage boundary server. Returns a handle to replay sources and a join handle to await termination.