Function amqpr_api::basic::deliver::get_delivered
[−]
[src]
pub fn get_delivered<S>(stream: S) -> Delivered<S> where
S: Stream<Item = Frame>,
S::Error: From<Error>,
Get DeliveredItem from given stream.
DeliveredItem consists of three things; DeliverMethod, ContentHeaderPayload and
ContentBodyPayload.
Notice
Maybe it is useful to use subscribe_stream. That function returns Stream of
DeliveredItem.
Error
Delivered future might be Error when stream: S yields unexpected frame.