streaming-platform 0.1.0

Data streaming platform and message broker with concurrent data transfer capabilities. 
1
2
3
4
5
6
7
8
9
10

#![recursion_limit="1024"]
#![feature(try_trait)]
pub use futures;
pub use tokio;
pub use sp_dto;
pub use proto::{LEN_BUF_SIZE, LENS_BUF_SIZE, DATA_BUF_SIZE, ServerConfig, ClientMsg, StreamLayout, StreamCompletion, ProcessStream, ProcessEvent, ProcessRpc, StreamStartup, Startup, MagicBall, ProcessError, RestreamMsg, StreamUnit};

mod proto;
pub mod server;
pub mod client;