automatically reconnect websocket if connection reset

[EverlastingBugstopper]

i would expect the following code snippet to work fine:

    let (ws_stream, _) = connect_async(socket_url)
        .await
        .expect("Failed to connect to websocket");

    let (mut write, read) = ws_stream.split();

    read.for_each(|message| async {
            let message = message.unwrap();
            let message_text = message.into_text().unwrap();
            println!("{}", message_text);
    }

but after waiting for not that long, the thread will panic at the unwrap on let message = message.unwrap()

thread 'tokio-runtime-worker' panicked at 'called `Result::unwrap()` on an `Err` value: Protocol("Connection reset without closing handshake")'

i'd expect tokio-tungstenite to handle this and attempt a reconnect. maybe that's a flawed expectation - if so, do y'all have recommendations on how to handle that protocol message?

[agalakhov]

We currently do not attempt to reconnect because we don't know what the disconnect means in the application. Sometimes disconnects are expected.

If there is no activity on TCP, the operating system will disconnect you sooner or later. If you don't have any better activity, send WebSocket ping messages periodically. This prevents disconnecting. If you do ping and still experience disconnects, this means network malfunction and is to be handled accordingly.