Remove clutter
This commit is contained in:
parent
fa42a1553c
commit
26af874126
1 changed files with 4 additions and 7 deletions
|
|
@ -108,13 +108,10 @@ async fn websocket(
|
||||||
Ok::<(), SyncServerError>(())
|
Ok::<(), SyncServerError>(())
|
||||||
});
|
});
|
||||||
|
|
||||||
let mut recv_task = tokio::spawn(async move {
|
let mut recv_task =
|
||||||
while let Some(Ok(Message::Text(text))) = receiver.next().await {
|
tokio::spawn(
|
||||||
info!("Received message: {}", text);
|
async move { while let Some(Ok(Message::Text(_text))) = receiver.next().await {} },
|
||||||
// Add username before message.
|
);
|
||||||
// let _ = tx.send(format!("{name}: {text}"));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
tokio::select! {
|
tokio::select! {
|
||||||
_ = &mut send_task => recv_task.abort(),
|
_ = &mut send_task => recv_task.abort(),
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue