Struct pea2pea::connections::Connection

pub struct Connection {
    pub addr: SocketAddr,
    pub reader: Option<OwnedReadHalf>,
    pub writer: Option<OwnedWriteHalf>,
    pub tasks: Vec<JoinHandle<()>>,
    pub outbound_message_sender: Option<Sender<Bytes>>,
    pub side: ConnectionSide,
}

Keeps track of tasks that have been spawned for the purposes of a connection; it also contains a sender that communicates with the Writing protocol handler.

Fields

addr: SocketAddr

The address of the connection.

reader: Option<OwnedReadHalf>

Kept only until the protocols are enabled (Reading should take() it).

writer: Option<OwnedWriteHalf>

Kept only until the protocols are enabled (Writing should take() it).

tasks: Vec<JoinHandle<()>>

Handles to tasks spawned by the connection.

outbound_message_sender: Option<Sender<Bytes>>

Used to queue writes to the stream.

side: ConnectionSide

The connection’s side in relation to the node.

Implementations

impl Connection

pub fn reader(&mut self) -> &mut OwnedReadHalf

Provides mutable access to the underlying reader; it should only be used in protocol definitions.

pub fn writer(&mut self) -> &mut OwnedWriteHalf

Provides mutable access to the underlying writer; it should only be used in protocol definitions.