1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! Stream protocol based on websocket
//! ```ignore
//! // the client want's to start a sender stream
//! Client > kind: SenderRequest action: "MyAction" data: request
//! // the server acknowledge the request / or sends a SenderClose
//! Server > kind: SenderRequest action: "MyAction" data: null
//! // the client can now start to send messages
//! Client > kind: SenderMessage action: "MyAction" data: message
//! // either the client or the server can send a SenderClose
//! // which will indicate that the stream should be terminated
//! Server > kind: SenderClose action: "MyAction" data: null|error
//! ```

pub mod message;
pub mod server;
mod stream;
pub mod streamer;
pub mod error;
pub mod util;

pub use server::StreamServer;
pub use stream::{StreamKind, Stream};
pub use error::StreamError;
pub use streamer::Streamer;