Struct UtpSocket

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

Expand description

A reference to an existing UtpSocket that can be shared amongst multiple tasks. This can’t function unless the corresponding UtpSocketDriver is scheduled to run on the same runtime.

Implementations§

impl UtpSocketRef

pub async fn bind<A: ToSocketAddrs>(addr: A) -> Result<Self>

Bind an unconnected UtpSocket on the given address.

pub async fn connect( self, dst: SocketAddr, ) -> Result<(UtpStream, UtpStreamDriver)>

Connect to a remote host using this UtpSocket

pub async fn accept(self) -> Result<(UtpStream, UtpStreamDriver)>

Accept an incoming connection using this UtpSocket. This also returns a UtpStreamDriver that must be scheduled on a runtime in order for the associated UtpStream to work properly. Accepting a new connection will consume this listener.

pub fn local_addr(&self) -> SocketAddr

Get the local address for this UtpSocket

Auto Trait Implementations§

impl Freeze for UtpSocketRef

impl !RefUnwindSafe for UtpSocketRef

impl Send for UtpSocketRef

impl Sync for UtpSocketRef

impl Unpin for UtpSocketRef

impl !UnwindSafe for UtpSocketRef

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more