tab-websocket 0.5.0

the websocket utility module for the tab terminal multiplexer
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use crate::WebsocketConnection;
use futures::SinkExt;
use log::error;
use tungstenite::{Error, Message};

/// Sends a close message over the provided websocket connection
pub async fn send_close(websocket: &mut WebsocketConnection) {
    if let Err(e) = websocket.send(Message::Close(None)).await {
        match e {
            Error::ConnectionClosed | Error::AlreadyClosed | Error::Protocol(_) => {
                return;
            }
            _ => {
                error!("failed to send close frame: {}", e);
            }
        }
    }
}

/// Checks if, given the message, the connection should be closed.
pub fn should_terminate(message: &Message) -> bool {
    if let Message::Close(_) = message {
        true
    } else {
        false
    }
}