fn spawn_channel_adapter(
client_rx: UnboundedReceiver<(Uuid, UnboundedReceiver<ComputeCommand>, UnboundedSender<ComputeResponse>)>,
command_tx: Sender,
response_rx: UnboundedReceiver<(ComputeResponse, Uuid)>,
worker_id: usize,
)Expand description
Spawn a task to bridge between ClusterClient and Worker channels.
The Worker expects a pair of persistent channels, with punctuation marking reconnects,
while the ClusterClient provides a new pair of channels on each reconnect.