Struct ClientNode 

pub struct ClientNode { /* private fields */ }

Implementations

impl ClientNode

pub async fn ack(&self, ack: MessageAck) -> Result<(), ClientNodeError>

pub async fn send_message( &self, message: EdgeMessage, ) -> Result<MessageAckHandle, ClientNodeError>

pub async fn send_message_and_wait( &self, message: EdgeMessage, ) -> Result<WaitAckSuccess, ClientNodeError>

pub async fn create_endpoint( &self, topic_code: TopicCode, interests: impl IntoIterator<Item = Interest>, ) -> Result<ClientEndpoint, ClientNodeError>

pub async fn connect<C>(connect: C) -> Result<Self, ClientNodeError>

where C: EdgeNodeConnection,

impl ClientNode

pub async fn connect_ws2<R: IntoClientRequest + Unpin>( req: R, codec: impl Codec + Clone, ) -> Result<ClientNode, ClientNodeError>

pub async fn connect_ws2_bincode<R: IntoClientRequest + Unpin>( req: R, ) -> Result<ClientNode, ClientNodeError>

pub async fn connect_ws2_json<R: IntoClientRequest + Unpin>( req: R, ) -> Result<ClientNode, ClientNodeError>

impl ClientNode

pub async fn send_event<E: Event>( &self, topic: TopicCode, event: E, ) -> Result<MessageAckHandle, ClientNodeError>

pub async fn send_event_and_wait<E: Event>( &self, topic: TopicCode, event: E, ) -> Result<WaitAckSuccess, ClientNodeError>

Trait Implementations

impl Clone for ClientNode

fn clone(&self) -> ClientNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClientNode

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

Formats the value using the given formatter.