Struct lib3h_zombie_actor::GhostParentWrapperDyn

pub struct GhostParentWrapperDyn<UserData, RequestToParent: 'static, RequestToParentResponse: 'static, RequestToChild: 'static, RequestToChildResponse: 'static, Error: 'static + Debug> { /* fields omitted */ }

same as above, but takes a trait object child

Methods

impl<UserData, RequestToParent: 'static, RequestToParentResponse: 'static, RequestToChild: 'static, RequestToChildResponse: 'static, Error: 'static + Debug> GhostParentWrapperDyn<UserData, RequestToParent, RequestToParentResponse, RequestToChild, RequestToChildResponse, Error>

pub fn new(
    actor: Box<dyn GhostActor<RequestToParent, RequestToParentResponse, RequestToChild, RequestToChildResponse, Error>>,
    request_id_prefix: &str
) -> Self

wrap a GhostActor instance and it's parent channel endpoint.

Trait Implementations

impl<UserData, RequestToParent: 'static, RequestToParentResponse: 'static, RequestToChild: 'static, RequestToChildResponse: 'static, Error: 'static + Debug> GhostCanTrack<UserData, RequestToChild, RequestToChildResponse, RequestToParent, RequestToParentResponse, Error> for GhostParentWrapperDyn<UserData, RequestToParent, RequestToParentResponse, RequestToChild, RequestToChildResponse, Error>

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

see GhostContextEndpoint::publish

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

see GhostContextEndpoint::request

fn request_options(
    &mut self,
    span: Span,
    payload: RequestToChild,
    cb: GhostCallback<UserData, RequestToChildResponse, 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<RequestToParent, RequestToChild, RequestToParentResponse, Error>>

see GhostContextEndpoint::drain_messages

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

see GhostContextEndpoint::process and GhostActor::process