Comprehensive Rust(Português do Brasil) 202412
de forma assíncrona de um stream de Websocket. • SinkExt::send() implementado por WebSocketStream: para enviar mensagens de forma assíncrona em um stream de Websocket. • Lines::next_line(): para ler mensagens bcast_tx = bcast_tx.clone(); tokio::spawn(async move { // Envolver o _stream_ TCP bruto em um _websocket_. let ws_stream = ServerBuilder::new().accept(socket).await?; handle_connection(addr, ws_stream bcast_tx = bcast_tx.clone(); tokio::spawn(async move { // Envolver o _stream_ TCP bruto em um _websocket_. let ws_stream = ServerBuilder::new().accept(socket).await?; handle_connection(addr, ws_stream0 码力 | 389 页 | 1.05 MB | 10 月前3
共 1 条
- 1