Struct Dispatch

pub struct Dispatch {
    pub id: Uuid,
    pub method: u64,
    pub body: Bytes,
    pub wait_for_response: bool,
}

Dispatch a message to appropriate handler

if id.is_nil() && !wait_for_response then the response is returned as soon as local link sent the message over the wire

Otherwise sets up a correlation counter and waits for response with a timeout(to prevent DOS attacks on correlation cache)

Fields

id: Uuid

method: u64

body: Bytes

wait_for_response: bool

Trait Implementations

impl Clone for Dispatch

fn clone(&self) -> Dispatch

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Dispatch

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Handler<Dispatch> for ProcessRegistry

type Result = Response<Bytes, DispatchError>

The type of value that this handler will return.

fn handle(&mut self, msg: Dispatch, ctx: &mut Context<Self>) -> Self::Result

This method is called for every message received by this actor.

impl Message for Dispatch

type Result = Result<Bytes, DispatchError>

The type of value that this message will resolved with if it is successful.