Struct ConnectionReader 

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

reader halve of the authenticated encrypted connection with the peer

Implementations

impl<PK> ConnectionReader<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 peer address we are receiving messages from

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> FusedStream for ConnectionReader<PK>

where PK: PublicKey,

fn is_terminated(&self) -> bool

Returns true if the stream should no longer be polled.

impl<PK> Stream for ConnectionReader<PK>

where PK: PublicKey,

type Item = Result<Bytes, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.