解を深めてください。 • WebSocketStream によって実装された StreamExt::next(): Websocket Stream からのメッ セージを非同期で読み取ります。 • WebSocketStream によって実装された SinkExt::send(): Websocket Stream 上でメッセー ジを非同期で送信します。 • Lines::next_line(): 標準入力からのユーザー from {addr:?}"); let bcast_tx = bcast_tx.clone(); tokio::spawn(async move { // 未加工の TCP ストリームを WebSocket にラップします。 let ws_stream = ServerBuilder::new().accept(socket).await?; handle_connection(addr, ws_stream from {addr:?}"); let bcast_tx = bcast_tx.clone(); tokio::spawn(async move { // 未加工の TCP ストリームを WebSocket にラップします。 370 let ws_stream = ServerBuilder::new().accept(socket).await?; handle_connection(addr