(
config: Arc<RwLock<ClientConfig>>,
opts: ClientOpts,
command_rx: mpsc::Receiver<Message>,
result_tx: mpsc::Sender<Message>,
)
| 556 | } |
| 557 | |
| 558 | pub async fn run_client( |
| 559 | config: Arc<RwLock<ClientConfig>>, |
| 560 | opts: ClientOpts, |
| 561 | command_rx: mpsc::Receiver<Message>, |
| 562 | result_tx: mpsc::Sender<Message>, |
| 563 | ) -> Result<()> { |
| 564 | let mut client = Client::<WebsocketTransport>::from(config, opts) |
| 565 | .await |
| 566 | .context("Failed to create Websocket client")?; |
| 567 | client.run(command_rx, result_tx).await |
| 568 | } |
| 569 | async fn handle_tcp_data_channel( |
| 570 | data_channel: Arc<DataChannel>, |
| 571 | local_addr: String, |