Struct UdpSocketRelay
pub struct UdpSocketRelay<S> { /* private fields */ }
Expand description
UdpSocketRelay
ready to relay udp packets.
This relay is not designed to be shared, as such it cannot be cloned and requires exclusive access.
Implementations§
§impl<S> UdpSocketRelay<S>
impl<S> UdpSocketRelay<S>
pub fn local_addr(&self) -> Result<SocketAddr, Error>
pub fn local_addr(&self) -> Result<SocketAddr, Error>
Returns the local address that this socket is bound to.
pub fn peer_addr(&self) -> Result<SocketAddr, Error>
pub fn peer_addr(&self) -> Result<SocketAddr, Error>
Returns the address of the (socks5) server connected to.
pub async fn send_to<A>(
&mut self,
b: &[u8],
addr: A,
) -> Result<usize, Box<dyn Error + Sync + Send>>where
A: TryInto<SocketAddress>,
<A as TryInto<SocketAddress>>::Error: Into<Box<dyn Error + Sync + Send>>,
pub async fn send_to<A>(
&mut self,
b: &[u8],
addr: A,
) -> Result<usize, Box<dyn Error + Sync + Send>>where
A: TryInto<SocketAddress>,
<A as TryInto<SocketAddress>>::Error: Into<Box<dyn Error + Sync + Send>>,
Sends data relayed via the socks5 udp associate proxy. On success, returns the number of bytes written.
pub fn poll_send_to<A>(
&mut self,
cx: &mut Context<'_>,
b: &[u8],
addr: A,
) -> Poll<Result<usize, Box<dyn Error + Sync + Send>>>where
A: TryInto<SocketAddress>,
<A as TryInto<SocketAddress>>::Error: Into<Box<dyn Error + Sync + Send>>,
pub fn poll_send_to<A>(
&mut self,
cx: &mut Context<'_>,
b: &[u8],
addr: A,
) -> Poll<Result<usize, Box<dyn Error + Sync + Send>>>where
A: TryInto<SocketAddress>,
<A as TryInto<SocketAddress>>::Error: Into<Box<dyn Error + Sync + Send>>,
Same as Self::send_to
but polled.
pub async fn recv_from(
&mut self,
buf: &mut [u8],
) -> Result<(usize, SocketAddress), Box<dyn Error + Sync + Send>>
pub async fn recv_from( &mut self, buf: &mut [u8], ) -> Result<(usize, SocketAddress), Box<dyn Error + Sync + Send>>
Receives a single datagram message from the socks5 udp associate proxy. On success, returns the number of bytes read and the origin.
The function must be called with valid byte array buf
of sufficient
size to hold the message bytes. If a message is too long to fit in the
supplied buffer, excess bytes may be discarded.
pub fn poll_recv_from(
&mut self,
cx: &mut Context<'_>,
buf: &mut ReadBuf<'_>,
) -> Poll<Result<SocketAddress, Box<dyn Error + Sync + Send>>>
pub fn poll_recv_from( &mut self, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<SocketAddress, Box<dyn Error + Sync + Send>>>
Same as Self::recv_from
but polled.
Note that on multiple calls to a poll_*
method in the recv
direction, only the
Waker
from the Context
passed to the most recent call will be scheduled to
receive a wakeup.
§Return value
The function returns:
Poll::Pending
if the socket is not ready to readPoll::Ready(Ok(addr))
reads data fromaddr
intoReadBuf
if the socket is readyPoll::Ready(Err(e))
if an error is encountered.
§Errors
This function may encounter any standard I/O error except WouldBlock
.
pub fn into_framed<C>(self, codec: C) -> UdpFramedRelay<C, S>
pub fn into_framed<C>(self, codec: C) -> UdpFramedRelay<C, S>
Consume this UdpSocketRelay
into a UdpFramedRelay
using the given C
codec.
Trait Implementations§
§impl<S> Debug for UdpSocketRelay<S>where
S: Debug,
impl<S> Debug for UdpSocketRelay<S>where
S: Debug,
§impl<S> Socket for UdpSocketRelay<S>
impl<S> Socket for UdpSocketRelay<S>
§fn local_addr(&self) -> Result<SocketAddr, Error>
fn local_addr(&self) -> Result<SocketAddr, Error>
§fn peer_addr(&self) -> Result<SocketAddr, Error>
fn peer_addr(&self) -> Result<SocketAddr, Error>
Auto Trait Implementations§
impl<S> !Freeze for UdpSocketRelay<S>
impl<S> RefUnwindSafe for UdpSocketRelay<S>where
S: RefUnwindSafe,
impl<S> Send for UdpSocketRelay<S>where
S: Send,
impl<S> Sync for UdpSocketRelay<S>where
S: Sync,
impl<S> Unpin for UdpSocketRelay<S>where
S: Unpin,
impl<S> UnwindSafe for UdpSocketRelay<S>where
S: UnwindSafe,
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Policy
that returns Action::Follow
only if self
and other
return
Action::Follow
. Read more