Struct PendingSession 

pub struct PendingSession<S> { /* private fields */ }

A stream whose first Noise message has been read but not yet processed.

This exists so that a responder can act on the initiator’s cleartext payload before deriving any keys. Everything up to PendingSession::into_session is reading and parsing, so a peer that is going to be turned away - one that is not an authorized validator, say - costs no scalar multiplications. Under a distributed flood of connection attempts, that is the difference between paying for five of them per rejected peer and paying for none.

Implementations

impl<S: AsyncRead + AsyncWrite + Unpin> PendingSession<S>

pub async fn accept(stream: S) -> Result<Self>

Reads the pattern’s first message from the given stream.

The caller is responsible for the NOISE_MAGIC prefix, which must already have been consumed with detect_handshake_protocol.

pub fn first_payload(&self) -> Result<&[u8]>

Returns the payload the initiator sent alongside its ephemeral key.

It is neither encrypted nor authenticated, so it is a claim and not a fact: anything acted on here has to be re-checked against the authenticated copy later in the handshake.

pub fn into_session(self) -> Result<NoiseSession<S>>

Derives the responder’s keys and processes the first message.