Struct EnvelopeEncryptedConnection 

pub struct EnvelopeEncryptedConnection { /* private fields */ }

A connection that runs Steam’s channel encryption handshake on top of another connection.

Implementations

impl EnvelopeEncryptedConnection

pub fn new(inner: Arc<dyn Connection>, universe: EUniverse) -> Self

Creates a new envelope connection wrapping inner.

pub fn with_debug_network_listener( inner: Arc<dyn Connection>, universe: EUniverse, debug_network_listener: Option<Arc<dyn DebugNetworkListener>>, ) -> Self

Creates a new envelope connection that reports the handshake messages to debug_network_listener.

pub fn subscribe_net_msg_received(&self) -> Receiver<NetMsgEventArgs>

Subscribes to the NetMsgReceived event.

pub fn subscribe_connected(&self) -> Receiver<()>

Subscribes to the Connected event.

pub fn subscribe_disconnected(&self) -> Receiver<DisconnectedEventArgs>

Subscribes to the Disconnected event.

Trait Implementations

impl ConnectionEvents for EnvelopeEncryptedConnection

fn events(&self) -> UnboundedReceiver<ConnectionEvent>

Subscribes to all three events as one stream.

fn net_msg_received(&self) -> Receiver<NetMsgEventArgs>

Subscribes to the NetMsgReceived event.

fn connected(&self) -> Receiver<()>

Subscribes to the Connected event.

fn disconnected(&self) -> Receiver<DisconnectedEventArgs>

Subscribes to the Disconnected event.

impl Debug for EnvelopeEncryptedConnection

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

Formats the value using the given formatter.

impl IConnection for EnvelopeEncryptedConnection

fn current_end_point(&self) -> Option<SocketAddr>

The remote endpoint of the current connection.

fn protocol_types(&self) -> ProtocolTypes

The type of communication protocol that this connection uses.

fn connect<'life0, 'async_trait>( &'life0 self, end_point: SocketAddr, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), SteamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connects to the specified endpoint.

fn disconnect<'life0, 'async_trait>( &'life0 self, user_initiated: bool, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnects. user_initiated is true when the caller asked for it.

fn send<'life0, 'async_trait>( &'life0 self, data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), SteamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends the specified data packet.

fn local_ip(&self) -> Option<IpAddr>

The local IP of the underlying socket, when one is bound.