Struct PeerConn 

pub struct PeerConn {
    peer: Arc<Peer>,
    proto_id: ProtocolID,
}

Per-protocol view of a Peer with the protocol id baked in. Built by karyon and handed to the protocol constructor. Hides the underlying proto_id routing so user code never types it.

Fields

peer: Arc<Peer>

proto_id: ProtocolID

Implementations

impl PeerConn

pub(crate) fn new(peer: Arc<Peer>, proto_id: ProtocolID) -> Self

karyon-internal constructor. User code receives a fully-built PeerConn from the protocol constructor closure.

pub async fn send(&self, payload: Vec<u8>) -> Result<()>

Send pre-encoded payload bytes to the peer on this protocol.

pub async fn recv(&self) -> Result<Vec<u8>>

Receive the next message bytes. Returns Err(PeerShutdown) when the peer is closing – callers can treat that as an orderly end of stream.

pub async fn broadcast(&self, payload: Vec<u8>)

Broadcast pre-encoded bytes to every connected peer on this protocol.

pub fn inner(&self) -> &Arc<Peer>

Underlying peer handle. Escape hatch for code that needs the raw Arc<Peer> (peer id, endpoint, lifecycle hooks).