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>,