Struct FeagiZmqClientRequester 

pub struct FeagiZmqClientRequester { /* private fields */ }

A ZMQ DEALER client that sends requests and receives responses.

Uses DEALER socket (async REQ) to allow non-blocking request/response flow. Uses reusable zmq::Message objects to minimize allocations.

Example

let props = FeagiZmqClientRequesterProperties::new("tcp://localhost:5557")?;
let mut requester = props.as_boxed_client_requester();

requester.request_connect()?;
while requester.poll() != FeagiEndpointState::ActiveWaiting {
    // wait for connection
}

requester.publish_request(b"Hello?")?;
loop {
    match requester.poll() {
        FeagiEndpointState::ActiveHasData => {
            let response = requester.consume_retrieved_response()?;
            process(response);
            break;
        }
        FeagiEndpointState::ActiveWaiting => { /* still waiting */ }
        _ => break,
    }
}

Trait Implementations

impl FeagiClient for FeagiZmqClientRequester

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 FeagiClientRequester for FeagiZmqClientRequester

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

Sends a request to the server.

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

Consumes and returns the retrieved response data.

fn as_boxed_requester_properties( &self, ) -> Box<dyn FeagiClientRequesterProperties>

Creates a boxed properties object for this requester.