Function amqpr_api::exchange::declare::declare_exchange_wait
[−]
[src]
pub fn declare_exchange_wait<In, Out, E>(
income: In,
outcome: Out,
channel_id: u16,
option: DeclareExchangeOption
) -> ExchangeDeclaredWait<In, Out> where
In: Stream<Error = E>,
Out: Sink<SinkItem = Frame, SinkError = E>,
E: From<Error>,
In::Item: Borrow<Frame>,
Declare exchange synchronously.
That means we will wait to receive Declare-Ok
method after send Declare
method.
If you want not to wait receiving, you should use declare_exchange
instead.
This function ignore "is_no_wait" flag of option.