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.