Trait splinter::network::dispatch::Handler

pub trait Handler<MT, T>: Send where
    MT: Hash + Eq + Debug + Clone,
    T: FromMessageBytes, {
    fn handle(
        &self, 
        message: T, 
        message_context: &MessageContext<MT>, 
        network_sender: &dyn Sender<SendRequest>
    ) -> Result<(), DispatchError>;
}

A Handler for a network message.

Required methods

fn handle(
    &self,
    message: T,
    message_context: &MessageContext<MT>,
    network_sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

Handles a given message

Errors

Any issues that occur during processing of the message will result in a DispatchError.

Loading content...

Implementors

impl Handler<CircuitMessageType, AdminDirectMessage> for AdminDirectMessageHandler

fn handle(
    &self,
    msg: AdminDirectMessage,
    context: &MessageContext<CircuitMessageType>,
    sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<CircuitMessageType, CircuitDirectMessage> for CircuitDirectMessageHandler

fn handle(
    &self,
    msg: CircuitDirectMessage,
    context: &MessageContext<CircuitMessageType>,
    sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<CircuitMessageType, CircuitError> for CircuitErrorHandler

fn handle(
    &self,
    msg: CircuitError,
    context: &MessageContext<CircuitMessageType>,
    sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<CircuitMessageType, ServiceConnectRequest> for ServiceConnectRequestHandler

fn handle(
    &self,
    msg: ServiceConnectRequest,
    context: &MessageContext<CircuitMessageType>,
    sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<CircuitMessageType, ServiceDisconnectRequest> for ServiceDisconnectRequestHandler

fn handle(
    &self,
    msg: ServiceDisconnectRequest,
    context: &MessageContext<CircuitMessageType>,
    sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<NetworkMessageType, AuthorizationMessage> for AuthorizationMessageHandler

fn handle(
    &self,
    msg: AuthorizationMessage,
    context: &MessageContext<NetworkMessageType>,
    _sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<NetworkMessageType, CircuitMessage> for CircuitMessageHandler

fn handle(
    &self,
    msg: CircuitMessage,
    context: &MessageContext<NetworkMessageType>,
    _: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<NetworkMessageType, NetworkEcho> for NetworkEchoHandler

fn handle(
    &self,
    msg: NetworkEcho,
    context: &MessageContext<NetworkMessageType>,
    sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl Handler<NetworkMessageType, NetworkHeartbeat> for NetworkHeartbeatHandler

fn handle(
    &self,
    _msg: NetworkHeartbeat,
    context: &MessageContext<NetworkMessageType>,
    _sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl<M: FromMessageBytes> Handler<NetworkMessageType, M> for NetworkAuthGuardHandler<M>

fn handle(
    &self,
    msg: M,
    context: &MessageContext<NetworkMessageType>,
    sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

impl<MT, T, F> Handler<MT, T> for F where
    MT: Hash + Eq + Debug + Clone,
    T: FromMessageBytes,
    F: Fn(T, &MessageContext<MT>, &dyn Sender<SendRequest>) -> Result<(), DispatchError> + Send, 

fn handle(
    &self,
    message: T,
    message_context: &MessageContext<MT>,
    network_sender: &dyn Sender<SendRequest>
) -> Result<(), DispatchError>

Loading content...