Function mz_storage::boundary::tcp_boundary::client::run_client

source · [−]

async fn run_client(
    stream: TcpStream, 
    announce_rx: UnboundedReceiver<Announce>, 
    storage_workers_tx: Sender<usize>, 
    workers: usize
) -> Result<()>

Expand description

Communicate data and subscriptions on stream, receiving local replay notifications on announce_rx. workers is the number of local Timely workers.