Function amqpr_api::basic::consume::start_consume

pub fn start_consume<S>(
    channel_id: u16, 
    socket: S, 
    option: StartConsumeOption
) -> ConsumeStarted<S> where
    S: Sink<SinkItem = Frame>,
    S::SinkError: From<Error>, 

Send Consume message to AMQP server.

Notice

A message being sent by this function is no-wait mode.