Function streaming_platform::client::full_message_mode

pub async fn full_message_mode<P: 'static, T: 'static, Q: 'static, R: 'static, '_, '_, '_>(
    host: &'_ str, 
    addr: &'_ str, 
    access_key: &'_ str, 
    process_event: ProcessEvent<T, P>, 
    process_rpc: ProcessRpc<Q, P>, 
    startup: Startup<R>, 
    config: HashMap<String, String>
) where
    T: Future<Output = Result<(), Box<dyn Error>>> + Send,
    Q: Future<Output = Result<Response<P>, Box<dyn Error>>> + Send,
    R: Future<Output = ()> + Send,
    P: Serialize,
    P: Deserialize<'de> + Send, 

Future for message based client based on provided config. "addr" value will be used as address for endpoint, "host" value - network addr for the server (in host:port format) "access_key" value will be send for optional authorization, more information about this feature will be provided later. process_stream is used for stream of incoming data processing. startup is executed on the start of this function. restream_rx can be used for restreaming data somewhere else, for example returning data for incoming web request The protocol message format is in sp-dto crate.