lapin 4.7.0

AMQP client library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use crate::{Connection, PromiseResolver, auth::AuthProvider};
use std::{fmt, sync::Arc};

pub(crate) enum ConnectionStep {
    ProtocolHeader(PromiseResolver<Connection>, Connection),
    StartOk(
        PromiseResolver<Connection>,
        Connection,
        Arc<dyn AuthProvider>,
    ),
    SecureOk(
        PromiseResolver<Connection>,
        Connection,
        Arc<dyn AuthProvider>,
    ),
}

impl ConnectionStep {
    pub(crate) fn name(&self) -> &'static str {
        match self {
            ConnectionStep::ProtocolHeader(..) => "ProtocolHeader",
            ConnectionStep::StartOk(..) => "StartOk",
            ConnectionStep::SecureOk(..) => "SecureOk",
        }
    }

    pub(crate) fn into_connection_resolver(
        self,
    ) -> (PromiseResolver<Connection>, Option<Connection>) {
        match self {
            ConnectionStep::ProtocolHeader(resolver, connection, ..) => {
                (resolver, Some(connection))
            }
            ConnectionStep::StartOk(resolver, connection, ..) => (resolver, Some(connection)),
            ConnectionStep::SecureOk(resolver, connection, ..) => (resolver, Some(connection)),
        }
    }
}

impl fmt::Debug for ConnectionStep {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "ConnectionStep::{}", self.name())
    }
}