Struct aldrin_broker::PendingConnection

pub struct PendingConnection<T: AsyncTransport + Unpin> { /* private fields */ }

A pending client connection, that hasn’t been accepted or rejected yet.

This type is acquired by BrokerHandle::begin_connect. It allows inspection of the client’s custom data and to accept or reject a client.

Dropping this type will simply also drop the transport. No message will be sent back to the client in this case.

Implementations

impl<T: AsyncTransport + Unpin> PendingConnection<T>

pub fn client_data(&self) -> &SerializedValueSlice

Returns the client’s data.

pub fn deserialize_client_data<D: Deserialize>( &self ) -> Result<D, DeserializeError>

Deserializes the client’s data.

pub async fn accept( self, broker_data: SerializedValue ) -> Result<Connection<T>, EstablishError<T::Error>>

Accepts a client and sends custom data back to it.

The resulting Connection must be run and polled to completion, much like the Broker itself.

pub async fn accept_serialize<D: Serialize + ?Sized>( self, broker_data: &D ) -> Result<Connection<T>, EstablishError<T::Error>>

Accepts a client and sends custom data back to it.

The resulting Connection must be run and polled to completion, much like the Broker itself.

pub async fn reject( self, broker_data: SerializedValue ) -> Result<(), EstablishError<T::Error>>

Rejects a client and sends custom data back to it.

pub async fn reject_serialize<D: Serialize + ?Sized>( self, broker_data: &D ) -> Result<(), EstablishError<T::Error>>

Rejects a client and sends custom data back to it.

Trait Implementations

impl<T: Debug + AsyncTransport + Unpin> Debug for PendingConnection<T>

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

Formats the value using the given formatter.