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

//! WebSocket receiver module.

use crate::{Message, Result, traits::WebSocketReceiverTrait};
use super::backend;

impl<Backend: WebSocketReceiverTrait> From<Backend> for WebSocketReceiver<Backend> {
    fn from(backend: Backend) -> Self {
        WebSocketReceiver { backend }
    }
}

/// Stream-based WebSocket receiver.
#[derive(Debug)]
pub struct WebSocketReceiver<Backend: WebSocketReceiverTrait = backend::WebSocketReceiver> {
    backend: Backend,
}

impl<Backend: WebSocketReceiverTrait> WebSocketReceiver<Backend> {
    /// Receives a message.
    pub async fn next(&mut self) -> Result<Option<Message>> {
        self.backend.next().await
    }
}