fn spawn_channel_adapter(
client_rx: Receiver<(Receiver<ComputeCommand>, UnboundedSender<ComputeResponse>)>,
command_tx: Sender,
response_rx: Receiver<(ComputeResponse, u64)>,
worker_id: usize,
)Expand description
Spawn a thread 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.