Struct ConnectionWriter 

pub struct ConnectionWriter<PK>
where
    PK: PublicKey,
{ /* private fields */ }

writer halve of the authenticated encrypted connection with the peer

Implementations

impl<PK> ConnectionWriter<PK>

where PK: PublicKey,

pub fn remote_public_identity(&self) -> &PK

retrieve the public identity of the peer

pub fn remote_address(&self) -> SocketAddr

the remote address we are sending messages to

beware that this may not reflect the peer’s actual address as they may be behind routers. Also this is not the same as the address that may be advertised by the peer in the gossip as they might use a different port number or a different routes for inbounds or outbound connections depending on their IT configuration.

pub fn session_id(&self) -> &SessionId

retrieve the unique identifier of the established session

this is derived from the NOISE handshake and is the same on both sides of the stream (here and for the remote).

Trait Implementations

impl<PK> Sink<Bytes> for ConnectionWriter<PK>

where PK: PublicKey,

type Error = Error

The type of value produced by the sink when an error occurs.

fn start_send(self: Pin<&mut Self>, item: Bytes) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.