pub async fn test_async_stream_pinned<TAsyncDuplex: AsyncRead + AsyncWrite + Send + ?Sized + 'static>( channel1: Pin<Box<TAsyncDuplex>>, channel2: Pin<Box<TAsyncDuplex>>, test_data: String)