Struct aggligator_util::transport::Connector

pub struct Connector { /* private fields */ }

Connects to remote endpoint using a variety of transports.

Dropping this does not terminate the connection or the transport connection task.

Implementations

impl Connector

pub fn new() -> Self

Creates a new connector using the default configuration.

Use ConnectorBuilder for customization.

pub fn wrapped(wrapper: impl ConnectingWrapper) -> Self

Creates a new connector using the default configuration and a single connection wrapper.

pub fn add(
    &self,
    transport: impl ConnectingTransport
) -> ConnectingTransportHandle

Adds a transport.

pub fn channel(&mut self) -> Option<Outgoing>

Waits for the connection to be established and obtains the aggregated link channel.

If this has been called before None is returned.

pub fn control(&self) -> Control<IoTxBox, IoRxBox, LinkTagBox>

Obtains the connection control of the aggregated connection.

pub fn available_tags(&self) -> HashSet<LinkTagBox>

Gets the current set of available link tags.

The set of available tags does not necesarilly match the set of connected tags. Use the connection control to obtain and monitor the set of connected tags.

pub fn available_tags_watch(&self) -> Receiver<HashSet<LinkTagBox>>

Watches the set of available link tags.

pub fn set_disabled_tags(&self, disabled_tags: HashSet<LinkTagBox>)

Sets the set of disabled link tags.

pub fn link_errors(&self) -> Receiver<LinkError<LinkTagBox>>

Subscribes to the stream of link errors.

Trait Implementations

impl Debug for Connector

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

Formats the value using the given formatter.

impl Default for Connector

fn default() -> Self

Returns the “default value” for a type.