test_framed_stream

connection_utils::test

Function test_framed_stream 

Source 
pub async fn test_framed_stream<TMessage: PartialEq + Clone + Debug + Random, TError: Debug, TEncoder: Encoder<TMessage> + Decoder<Item = TMessage, Error = TError>, TAsyncDuplex: AsyncRead + AsyncWrite + ?Sized>(
    stream1: Framed<Pin<Box<TAsyncDuplex>>, TEncoder>,
    stream2: Framed<Pin<Box<TAsyncDuplex>>, TEncoder>,
    options: TestOptions,
) -> (Framed<Pin<Box<TAsyncDuplex>>, TEncoder>, Framed<Pin<Box<TAsyncDuplex>>, TEncoder>)
where
    <TEncoder as Encoder<TMessage>>::Error: Debug,
Expand description

Test data transfer in a framed stream. First passes data in forward direction and validates that all data trassfered without issues. Then make another pass in backward direction with the same validation.