[−][src]Crate streaming_platform
Re-exports
pub use futures; |
pub use tokio; |
pub use sp_dto; |
Modules
client | |
server |
Structs
MagicBall | |
ServerConfig | |
StreamLayout |
Enums
ClientMsg | Messages received from client |
ProcessError | |
RestreamMsg | |
StreamCompletion | |
StreamUnit |
Constants
DATA_BUF_SIZE | |
LENS_BUF_SIZE | |
LEN_BUF_SIZE |
Type Definitions
ProcessEvent | Type for function called on event processing with json payload |
ProcessRpc | Type for function called on rpc processing with json payload |
ProcessStream | Type for function called on data stream processing |
Startup | Type for function called on client starting |
StreamStartup | Type for function called on stream client starting |