Struct FeagiWebSocketServerPuller 

pub struct FeagiWebSocketServerPuller { /* private fields */ }

A WebSocket server that receives pushed data from clients.

Trait Implementations

impl FeagiServer for FeagiWebSocketServerPuller

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 FeagiServerPuller for FeagiWebSocketServerPuller

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

Consumes and returns the retrieved data from clients.

fn as_boxed_puller_properties(&self) -> Box<dyn FeagiServerPullerProperties>

Creates a boxed properties object for this puller.