pub async fn proxy_stream<S, T>(s1: S, s2: T) -> Result<(), Error>where S: Sink<Message, Error = Error> + Stream<Item = Result<Message, Error>> + Unpin, T: Sink<Message, Error = Error> + Stream<Item = Result<Message, Error>> + Unpin,
Proxies two streams.
s1
s2