wamp_async 0.3.1

use async_trait::async_trait;
use quick_error::*;

pub mod tcp;
pub use tcp::*;

pub mod websocket;
pub use crate::transport::websocket as ws;
pub use ws::*;

#[async_trait]
pub trait Transport {
    /// Sends a whole wamp message over the transport
    async fn send(&mut self, data: &[u8]) -> Result<(), TransportError>;
    /// Receives a whole wamp message from the transport
    async fn recv(&mut self) -> Result<Vec<u8>, TransportError>;
    /// Closes the transport connection with the host
    async fn close(&mut self);
}

quick_error! {
    #[derive(Debug)]
    pub enum TransportError {
        MaximumServerConn {
            display("Server hit the maximum connection count")
        }
        UnexpectedResponse {
            display("Server responded with unexpected data")
        }
        SerializerNotSupported(e: String) {
            display("The current serializer is not supported by the server (Requested : {})", e)
        }
        InvalidMaximumMsgSize(e: u32) {
            display("The server did not accept the maximum payload size (Requested : {})", e)
        }
        ConnectionFailed {
            display("Failed to negotiate connection with the server")
        }
        SendFailed {
            display("Failed to send message to peer")
        }
        ReceiveFailed {
            display("Failed to receive message from peer")
        }
    }
}