Struct UdpStream

pub struct UdpStream<P: RuntimeProvider> { /* private fields */ }

A UDP stream of DNS binary packets

Implementations

impl<P: RuntimeProvider> UdpStream<P>

pub fn new( remote_addr: SocketAddr, bind_addr: Option<SocketAddr>, avoid_local_ports: Option<Arc<HashSet<u16>>>, provider: P, ) -> (Box<dyn Future<Output = Result<Self, Error>> + Send + Unpin>, BufDnsStreamHandle)

This method is intended for client connections, see Self::with_bound for a method better for straight listening. It is expected that the resolver wrapper will be responsible for creating and managing new UdpStreams such that each new client would have a random port (reduce chance of cache poisoning). This will return a randomly assigned local port, unless a nonzero port number is specified in bind_addr.

Arguments

• remote_addr - socket address for the remote connection (used to determine IPv4 or IPv6)
• bind_addr - optional local socket address to connect from (if a nonzero port number is specified, it will be used instead of randomly selecting a port)
• provider - async runtime provider, for I/O and timers

Return

A tuple of a Future of a Stream which will handle sending and receiving messages, and a handle which can be used to send messages into the stream.

impl<P: RuntimeProvider> UdpStream<P>

pub fn with_bound( socket: P::Udp, remote_addr: SocketAddr, ) -> (Self, BufDnsStreamHandle)

Initialize the Stream with an already bound socket. Generally this should be only used for server listening sockets. See Self::new for a client oriented socket. Specifically, this requires there is already a bound socket, whereas new makes sure to randomize ports for additional cache poison prevention.

Arguments

• socket - an already bound UDP socket
• remote_addr - remote side of this connection

Return

A tuple of a Stream which will handle sending and receiving messages, and a handle which can be used to send messages into the stream.

Trait Implementations

impl<P: RuntimeProvider> Stream for UdpStream<P>

type Item = Result<SerialMessage, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.