Struct trust_dns_proto::udp::UdpStream

pub struct UdpStream<S: Send> { /* private fields */ }

A UDP stream of DNS binary packets

Implementations

impl<S: UdpSocket + Send + 'static> UdpStream<S>

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

This method is intended for client connections, see 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.

Arguments

• remote_addr - socket address for the remote connection (used to determine IPv4 or IPv6)

Return

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

impl<S: DnsUdpSocket + Send + 'static> UdpStream<S>

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

Initialize the Stream with an already bound socket. Generally this should be only used for server listening sockets. See new for a client oriented socket. Specifically, this there is already a bound socket in this context, 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 Future Stream which will handle sending and receiving messages, and a handle which can be used to send messages into the stream.

Trait Implementations

impl<S: DnsUdpSocket + Send + 'static> Stream for UdpStream<S>

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.