Struct FeagiWebSocketServerPublisher 

pub struct FeagiWebSocketServerPublisher { /* private fields */ }

A WebSocket server that broadcasts data to all connected clients.

Implementations

impl FeagiWebSocketServerPublisher

pub fn client_count(&self) -> usize

Get the number of connected clients.

Trait Implementations

impl FeagiServer for FeagiWebSocketServerPublisher

fn poll(&mut self) -> &FeagiEndpointState

Advances the internal state machine and returns the current state.

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

Initiates binding to the configured address and starts listening.

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

Initiates stopping the server and unbinding from the address.

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

Acknowledges an error and closes the server.

fn get_bind_point(&self) -> TransportProtocolEndpoint

Gets the local bind point

fn get_agent_endpoint(&self) -> TransportProtocolEndpoint

Gets the bind point that is given to agents (the remote bind point)

fn get_protocol(&self) -> TransportProtocolImplementation

impl FeagiServerPublisher for FeagiWebSocketServerPublisher

fn publish_data(&mut self, data: &[u8]) -> Result<(), FeagiNetworkError>

Broadcasts data to all connected subscribers.

fn as_boxed_publisher_properties( &self, ) -> Box<dyn FeagiServerPublisherProperties>

Creates a boxed properties object for this publisher.