Type Definition streaming_platform::ProcessStream

type ProcessStream<T> = fn(_: HashMap<String, String>, _: MagicBall, _: UnboundedReceiver<ClientMsg>, _: Option<UnboundedReceiver<RestreamMsg>>) -> T;

Type for function called on data stream processing