Skip to main content

tcp_multi_connection

hydro_deploy_integration::multi_connection

Function tcp_multi_connection 

Source 
pub fn tcp_multi_connection<I, C>(
    listener: TcpListener,
) -> (TcpMultiConnectionSource<C>, TcpMultiConnectionSink<I, C>, UnboundedReceiverStream<(u64, bool)>)
where
    C: Decoder + Encoder<I> + Default,