Function dbcrossbarlib::tokio_glue::try_forward [−][src]
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>,
Expand description
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.