Struct OpenSession 

pub struct OpenSession { /* private fields */ }

Open new session

Implementations

impl OpenSession

pub fn offered_capabilities(self, caps: Symbols) -> Self

Set session offered capabilities

pub fn desired_capabilities(self, caps: Symbols) -> Self

Set session desired capabilities

pub fn property<K, V>(self, key: K, value: V) -> Self

where K: Into<Symbol>, V: Into<Variant>,

Set session property

pub async fn attach(self) -> Result<Session, AmqpProtocolError>

Attach session

Trait Implementations

impl Future for OpenSession

type Output = Result<Session, AmqpProtocolError>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.