Skip to main content

forward_messages

mz_compute_client::controller::sequential_hydration

Function forward_messages 

Source 
async fn forward_messages<C>(
    client: C,
    rx: UnboundedReceiver<ComputeCommand>,
    tx: UnboundedSender<Result<ComputeResponse, Error>>,
)
where
    C: ComputeClient,
Expand description

Forward messages between a pair of channels and a ComputeClient.

This functions is run in its own task and exists to allow SequentialHydration::recv to be cancel safe even though it needs to send commands to the wrapped client, which isn’t cancel safe.