Struct RelayCarrier 

pub struct RelayCarrier { /* private fields */ }

An ordinary wire connection to the relay on its admitted relay stream.

Implementations

impl RelayCarrier

pub fn new( socket: TcpStream, stream_id: u32, relay: MachineIdentity, ) -> Result<Self, CarrierError>

Takes a connection whose relay stream has been granted and marked.

Errors

Stream zero is reserved for connection control.

pub fn interrupt_handle(&self) -> Result<TcpStream, CarrierError>

Interrupts a blocking receive through the same owned socket.

Errors

The socket cannot be duplicated.

pub fn acknowledge( &mut self, message_id: u64, durable_position: Option<u64>, ) -> Result<(), CarrierError>

Answers an imported frame; the relay carries the full receipt back.

Errors

The carrier has ended or the ordinary connection cannot send the ack.

pub fn refuse( &mut self, reason_code: u16, reason: &str, ) -> Result<(), CarrierError>

Answers a named endpoint refusal on the relay stream.

Errors

The carrier has ended or the ordinary connection cannot send the refusal.

pub fn topology( &self, local: MachineIdentity, peer: MachineIdentity, counters: LinkCounters, ) -> Link

The topology record for the endpoint’s observed relayed link.

Trait Implementations

impl Debug for RelayCarrier

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl LinkCarrier for RelayCarrier

fn refuse_unsolicited(&self) -> Result<(), CarrierError>

Errors

fn carrier(&self) -> Carrier

Which carrier holds this path.

fn ended(&self) -> Option<String>

The end this carrier observed, by name, once it has one: the peer’s close reason, wire_eof, or the failure that ended it. None while the carrier is live.

fn send(&mut self, subject: &str, sealed: &[u8]) -> Result<(), CarrierError>

Sends one subject and its sealed bytes.

fn receive(&mut self) -> Result<CarrierReceive, CarrierError>

Receives the next sealed bytes, or the carrier’s named end.