Function amqpr_api::basic::consume::start_consume_wait

pub fn start_consume_wait<In, Out, E>(
    income: In, 
    outcome: Out, 
    channel_id: u16, 
    option: StartConsumeOption
) -> ConsumeStarted<In, Out> where
    In: Stream<Error = E>,
    In::Item: Borrow<Frame>,
    Out: Sink<SinkItem = Frame, SinkError = E>,
    E: From<Error>,