Struct FeagiWebSocketClientSubscriber 

pub struct FeagiWebSocketClientSubscriber { /* private fields */ }

A WebSocket client that subscribes to data from a publisher server.

Trait Implementations

impl FeagiClient for FeagiWebSocketClientSubscriber

fn poll(&mut self) -> &FeagiEndpointState

Advances the internal state machine and returns the current state.

fn request_connect(&mut self) -> Result<(), FeagiNetworkError>

Initiates a connection to the configured server address.

fn request_disconnect(&mut self) -> Result<(), FeagiNetworkError>

Initiates disconnection from the server.

fn confirm_error_and_close(&mut self) -> Result<(), FeagiNetworkError>

Acknowledges an error and closes the connection.

fn get_endpoint_target(&self) -> TransportProtocolEndpoint

impl FeagiClientSubscriber for FeagiWebSocketClientSubscriber

fn consume_retrieved_data(&mut self) -> Result<&[u8], FeagiNetworkError>

Consumes and returns the retrieved subscription data.

fn as_boxed_subscriber_properties( &self, ) -> Box<dyn FeagiClientSubscriberProperties>

Creates a boxed properties object for this subscriber.