Struct ConnectionInner 

pub(crate) struct ConnectionInner {

    server_guid: OwnedGuid,
    cap_unix_fd: bool,
    unique_name: OnceLock<OwnedUniqueName>,
    registered_names: Mutex<HashMap<WellKnownName<'static>, NameStatus>>,
    activity_event: Arc<Event>,
    socket_write: Mutex<Box<dyn WriteHalf>>,
    executor: Executor<'static>,
    socket_reader_task: OnceLock<Task<()>>,
    pub(crate) msg_receiver: InactiveReceiver<Result<Message>>,
    pub(crate) method_return_receiver: InactiveReceiver<Result<Message>>,
    msg_senders: Arc<Mutex<HashMap<Option<OwnedMatchRule>, Sender<Result<Message>>>>>,
    subscriptions: Mutex<HashMap<OwnedMatchRule, (u64, InactiveReceiver<Result<Message>>)>>,
    object_server: OnceLock<ObjectServer>,
    object_server_dispatch_task: OnceLock<Task<()>>,
    drop_event: Event,
    method_timeout: Option<Duration>,
}

Inner state shared by Connection and WeakConnection

Fields

server_guid: OwnedGuid

cap_unix_fd: bool

unique_name: OnceLock<OwnedUniqueName>

registered_names: Mutex<HashMap<WellKnownName<'static>, NameStatus>>

activity_event: Arc<Event>

socket_write: Mutex<Box<dyn WriteHalf>>

executor: Executor<'static>

socket_reader_task: OnceLock<Task<()>>

msg_receiver: InactiveReceiver<Result<Message>>

method_return_receiver: InactiveReceiver<Result<Message>>

msg_senders: Arc<Mutex<HashMap<Option<OwnedMatchRule>, Sender<Result<Message>>>>>

subscriptions: Mutex<HashMap<OwnedMatchRule, (u64, InactiveReceiver<Result<Message>>)>>

object_server: OnceLock<ObjectServer>

object_server_dispatch_task: OnceLock<Task<()>>

drop_event: Event

method_timeout: Option<Duration>

Trait Implementations

impl Debug for ConnectionInner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for ConnectionInner

fn drop(&mut self)

Executes the destructor for this type.