Struct ResponseReaction 

pub struct ResponseReaction {
    pub to_addressee: Option<Action<ResponseFrame, ResponseFrame>>,
    pub to_sender: Option<Action<ResponseFrame, RequestFrame>>,
    pub drop_connection: Option<Option<Duration>>,
    pub feedback_channel: Option<UnboundedSender<(ResponseFrame, Option<TargetShard>)>>,
}

Fields

to_addressee: Option<Action<ResponseFrame, ResponseFrame>>

to_sender: Option<Action<ResponseFrame, RequestFrame>>

drop_connection: Option<Option<Duration>>

feedback_channel: Option<UnboundedSender<(ResponseFrame, Option<TargetShard>)>>

Trait Implementations

impl Clone for ResponseReaction

fn clone(&self) -> ResponseReaction

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResponseReaction

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

Formats the value using the given formatter.

impl Reaction for ResponseReaction

type Incoming = ResponseFrame

type Returning = RequestFrame

fn noop() -> Self

Does nothing extraordinary, i.e. passes the frame with no changes to it.

fn drop_frame() -> Self

Drops frame, i.e. passes it into void.

fn delay(time: Duration) -> Self

Passes the frame only after specified delay.

fn forge_response( f: Arc<dyn Fn(Self::Incoming) -> Self::Returning + Send + Sync>, ) -> Self

Instead of passing the frame to the addressee, returns the forged frame back to the addresser.

fn forge_response_with_delay( time: Duration, f: Arc<dyn Fn(Self::Incoming) -> Self::Returning + Send + Sync>, ) -> Self

The same as forge_response, but with specified delay.

fn transform_frame( f: Arc<dyn Fn(Self::Incoming) -> Self::Incoming + Send + Sync>, ) -> Self

Pass the frame to the adressee, but modify it first.

fn drop_connection() -> Self

Drops the frame AND drops the connection with both the driver and the cluster.

fn drop_connection_with_delay(time: Duration) -> Self

The same as drop_connection, but with specified delay.

fn with_feedback_when_performed( self, tx: UnboundedSender<(Self::Incoming, Option<TargetShard>)>, ) -> Self

Adds sending the matching frame as feedback using the provided channel. Modifies the existing Reaction.