Function dbcrossbarlib::tokio_glue::try_forward

pub async fn try_forward<T, St, Si>(stream: St, sink: Si) -> Result<()> where
    St: Stream<Item = Result<T>> + Unpin,
    Si: Sink<T> + Unpin,
    Error: From<Si::Error>, 

Copy stream into sink. If stream returns an Err value, stop immediately.

This is basically similar to [futures::StreamExt::forward], except that we return an error of type Error, and not of type <Si as Sink>::Error, which makes things more flexible.