pub async fn stream_forward(
left: impl UniversalStream<Vec<u8>, NetworkError>,
right: impl UniversalStream<Vec<u8>, NetworkError>,
) -> Result<(), NetworkError>pub async fn stream_forward(
left: impl UniversalStream<Vec<u8>, NetworkError>,
right: impl UniversalStream<Vec<u8>, NetworkError>,
) -> Result<(), NetworkError>