Struct CompositeEndpoint 

pub struct CompositeEndpoint<E> { /* private fields */ }

An ordered collection of endpoints of one type. Connecting tries children in order until one succeeds. Binding creates every child’s listeners and rolls them all back if a later child fails. Empty collections fail with AddrNotAvailable.

Implementations

impl<E> CompositeEndpoint<E>

pub fn new(endpoints: Vec<E>) -> Self

Describe an ordered collection, without performing I/O.

pub fn endpoints(&self) -> &[E]

The child endpoint descriptions in attempt order.

Trait Implementations

impl<S, E> BindEndpoint<S> for CompositeEndpoint<E>

where S: SocketClose<Socket = E::Listener> + ?Sized, E: BindEndpoint<S>,

type Listener = <E as BindEndpoint<S>>::Listener

One bound listener, owned by the caller on success. Its representation belongs to the endpoint implementation.

async fn bind( &self, scheduler: &S, options: BindOptions, cancellation: &Cancellation, ) -> OperationResult<Vec<Self::Listener>>

Bind and start listening on every address. Success returns a nonempty collection; failure transfers no listeners to the caller. Futures are lazy. Await completion after cooperative cancellation to finish asynchronous rollback; dropping a pending future provides ordinary destruction only.

impl<E: Clone> Clone for CompositeEndpoint<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S, E> ConnectEndpoint<S> for CompositeEndpoint<E>

where S: Sync + ?Sized, E: ConnectEndpoint<S>,

type Connection = <E as ConnectEndpoint<S>>::Connection

The established transport, owned by the caller on success.

async fn connect( &self, scheduler: &S, cancellation: &Cancellation, ) -> OperationResult<Self::Connection>

Establish one connection. Futures are lazy. Await completion after requesting cooperative cancellation so implementation-owned asynchronous cleanup can finish. Dropping a future abandons it and provides ordinary resource destruction, not an asynchronous cleanup guarantee.

impl<E: Debug> Debug for CompositeEndpoint<E>

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

Formats the value using the given formatter.

impl<E: Eq> Eq for CompositeEndpoint<E>

impl<E: PartialEq> PartialEq for CompositeEndpoint<E>

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<E: PartialEq> StructuralPartialEq for CompositeEndpoint<E>