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