Struct lib3h_zombie_actor::GhostContextEndpoint

pub struct GhostContextEndpoint<UserData, RequestToOther: 'static, RequestToOtherResponse: 'static, RequestToSelf: 'static, RequestToSelfResponse: 'static, Error: 'static + Debug> { /* fields omitted */ }

an expanded endpoint usable to send/receive requests/responses/events see GhostEndpoint::as_context_endpoint_builder for additional details

Trait Implementations

impl<UserData, RequestToOther: 'static, RequestToOtherResponse: 'static, RequestToSelf: 'static, RequestToSelfResponse: 'static, Error: 'static + Debug> GhostCanTrack<UserData, RequestToOther, RequestToOtherResponse, RequestToSelf, RequestToSelfResponse, Error> for GhostContextEndpoint<UserData, RequestToOther, RequestToOtherResponse, RequestToSelf, RequestToSelfResponse, Error>

fn publish(&mut self, span: Span, payload: RequestToOther) -> GhostResult<()>

publish an event to the remote side, not expecting a response

fn request(
    &mut self,
    span: Span,
    payload: RequestToOther,
    cb: GhostCallback<UserData, RequestToOtherResponse, Error>
) -> GhostResult<()>

make a request of the other side. When a response is sent back to us the callback will be invoked.

fn request_options(
    &mut self,
    span: Span,
    payload: RequestToOther,
    cb: GhostCallback<UserData, RequestToOtherResponse, Error>,
    options: GhostTrackRequestOptions
) -> GhostResult<()>

make a request of the other side. When a response is sent back to us the callback will be invoked, override the default timeout.

fn drain_messages(
    &mut self
) -> Vec<GhostMessage<RequestToSelf, RequestToOther, RequestToSelfResponse, Error>>

fetch any messages (requests or events) sent to us from the other side

fn process(&mut self, user_data: &mut UserData) -> GhostResult<WorkWasDone>

check for pending responses timeouts or incoming messages