Function amqpr_api::channel::open::open_channel [] [src]

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