cross-ws 0.3.3

cross-ws is a web and native stream based WebSocket client
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

#[cfg(test)]
mod tests {
    use cross_ws::{WebSocket, Message};
    use cross_test::prelude::*;

    cross_test_configure!();

    #[cross_test]
    async fn connection_failure() {
        WebSocket::new("wss://nonexistent.domain").await.expect_err("Couldn't connect");
    }

    #[cross_test]
    async fn send_after_close() {
        let (mut sender, _) = WebSocket::new("wss://echo.websocket.org").await.expect("Couldn't connect");

        sender.close(None).await.expect("Failed to close WebSocket.");

        let expected_message_1 = Message::Text("Hello".into());
        sender.send(expected_message_1.clone()).await.expect_err("Sending after closing is not allowed.");
    }

    #[cross_test]
    async fn echo() {
        let (mut sender, mut receiver) = WebSocket::new("wss://echo.websocket.org").await.expect("Couldn't connect");

        assert!(receiver.next().await.expect("Failed to receive message.").expect("Stream has terminated.").as_text().unwrap().contains("Request served by"));

        let expected_message_1 = Message::Text("Hello".into());
        sender.send(expected_message_1.clone()).await.expect("Couldn't send text message 1.");

        let expected_message_2 = Message::Binary(vec![1, 2, 3]);
        sender.send(expected_message_2.clone()).await.expect("Couldn't send text message 2.");

        let expected_message_3 = Message::Text("Echo".into());
        sender.send(expected_message_3.clone()).await.expect("Couldn't send binary message 3.");

        let message = receiver.next().await.expect("Failed to receive message 1.").expect("Stream has terminated at message 1.");
        assert_eq!(message, expected_message_1, "Unexpected message 1.");

        let message = receiver.next().await.expect("Failed to receive message 2.").expect("Stream has terminated at message 2.");
        assert_eq!(message, expected_message_2, "Unexpected message 2.");

        let message = receiver.next().await.expect("Failed to receive message 3.").expect("Stream has terminated at message 3.");
        assert_eq!(message, expected_message_3, "Unexpected message 3.");
    }
}