Struct quic_rpc::transport::quinn_flume_socket::FlumeSocket

pub struct FlumeSocket(/* private fields */);

An implementation of quinn::AsyncUdpSocket that uses flume channels

Implementations

impl FlumeSocket

pub fn new(local: SocketAddr, tx: Sender<Packet>, rx: Receiver<Packet>) -> Self

Create a new flume socket, with the given local address.

Sent packets will have from set to the local address, and received packets with to not set to the local address will be ignored.

Trait Implementations

impl AsyncUdpSocket for FlumeSocket

fn poll_send( &self, state: &UdpState, cx: &mut Context<'_>, transmits: &[Transmit] ) -> Poll<Result<usize, Error>>

Send UDP datagrams from transmits, or register to be woken if sending may succeed in the future

fn poll_recv( &self, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], meta: &mut [RecvMeta] ) -> Poll<Result<usize>>

Receive UDP datagrams, or register to be woken if receiving may succeed in the future

fn local_addr(&self) -> Result<SocketAddr>

Look up the local IP address and port used by this socket

fn may_fragment(&self) -> bool

Whether datagrams might get fragmented into multiple parts

impl Debug for FlumeSocket

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

Formats the value using the given formatter.