Struct ChainedHandler 

pub struct ChainedHandler<M, H, T> {
    pub matcher: M,
    pub handler: H,
    pub next: T,
}

A handler that chains two handlers together in a composite handler.

Fields

matcher: M

The matcher that determines whether the handler should be invoked for the incoming operation.

handler: H

The handler to be invoked if the matcher returns true.

next: T

The next handler to be invoked if the matcher returns false.

Implementations

impl<M, H, T> ChainedHandler<M, H, T>

pub const fn new(matcher: M, handler: H, next: T) -> ChainedHandler<M, H, T>

Construct a chained handler that works as follows:

• It will call the provided handler instance if the provided matcher returns true for the ReadContext/WriteContext/InvokeContext of the incoming operation
• Otherwise, it will call the next handler

Arguments:

• matcher: A matcher that determines whether the handler should be invoked for the incoming operation.
• handler: The handler to be invoked if the matcher returns true.
• next: The next handler to be invoked if the matcher returns false.

pub const fn chain<M2, H2>( self, matcher: M2, handler: H2, ) -> ChainedHandler<M2, H2, ChainedHandler<M, H, T>>

Chain itself with another handler.

The returned chained handler works as follows:

• It will call the provided handler instance if the provided matcher returns true for the ReadContext/WriteContext/InvokeContext of the incoming operation
• Otherwise, it will call the self handler

Arguments:

• matcher: A matcher that determines whether the handler should be invoked for the incoming operation.
• handler: The handler to be invoked if the matcher returns true.

Trait Implementations

impl<M, H, T> AsyncHandler for ChainedHandler<M, H, T>

where M: Matcher, H: AsyncHandler, T: AsyncHandler,

fn read_awaits(&self, ctx: impl ReadContext) -> bool

Provide information whether the handler will internally await while reading the current value of the provided attribute.

fn write_awaits(&self, ctx: impl WriteContext) -> bool

Provide information whether the handler will internally await while updating the value of the provided attribute.

fn invoke_awaits(&self, ctx: impl InvokeContext) -> bool

Provide information whether the handler will internally await while invoking the provided command.

fn read( &self, ctx: impl ReadContext, reply: impl ReadReply, ) -> impl Future<Output = Result<(), Error>>

Read from the requested attribute and encode the result using the provided reply type.

fn write( &self, ctx: impl WriteContext, ) -> impl Future<Output = Result<(), Error>>

Write into the requested attribute using the provided data.

fn invoke( &self, ctx: impl InvokeContext, reply: impl InvokeReply, ) -> impl Future<Output = Result<(), Error>>

Invoke the requested command with the provided data and encode the result using the provided reply type.

fn bump_dataver(&self, ctx: impl MatchContext)

Bump the per-cluster Dataver for the cluster handler matching the supplied context endpoint_id / cluster_id.

fn lifecycle( &self, ctx: impl HandlerContext, op: LifecycleOp, ) -> Result<(), Error>

Process a lifecycle operation (LifecycleOp).

async fn run(&self, ctx: impl HandlerContext) -> Result<(), Error>

A hook (a scheduling facility) for placing handler-impl-specific code that needs to run asynchronously - forever and in the “background”.

impl<M, H, T> Clone for ChainedHandler<M, H, T>

where M: Clone, H: Clone, T: Clone,

fn clone(&self) -> ChainedHandler<M, H, T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M, H, T> Copy for ChainedHandler<M, H, T>

where M: Copy, H: Copy, T: Copy,

impl<M, H, T> Debug for ChainedHandler<M, H, T>

where M: Debug, H: Debug, T: Debug,

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

Formats the value using the given formatter.

impl<M, H, T> Eq for ChainedHandler<M, H, T>

where M: Eq, H: Eq, T: Eq,

impl<M, H, T> Handler for ChainedHandler<M, H, T>

where M: Matcher, H: Handler, T: Handler,

fn read( &self, ctx: impl ReadContext, reply: impl ReadReply, ) -> Result<(), Error>

Read from the requested attribute and encode the result using the provided reply type.

fn write(&self, ctx: impl WriteContext) -> Result<(), Error>

Write into the requested attribute using the provided data.

fn invoke( &self, ctx: impl InvokeContext, reply: impl InvokeReply, ) -> Result<(), Error>

Invoke the requested command with the provided data and encode the result using the provided reply type.

fn bump_dataver(&self, ctx: impl MatchContext)

Bump the per-cluster Dataver for the cluster handler matching the supplied context endpoint_id / cluster_id.

fn lifecycle( &self, ctx: impl HandlerContext, op: LifecycleOp, ) -> Result<(), Error>

Process a lifecycle operation (LifecycleOp).

async fn run(&self, ctx: impl HandlerContext) -> Result<(), Error>

A hook (a scheduling facility) for placing handler-impl-specific code that needs to run asynchronously - forever and in the “background”.

impl<M, H, T> Hash for ChainedHandler<M, H, T>

where M: Hash, H: Hash, T: Hash,

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<M, H, T> NonBlockingHandler for ChainedHandler<M, H, T>

where M: Matcher, H: NonBlockingHandler, T: NonBlockingHandler,

impl<M, H, T> PartialEq for ChainedHandler<M, H, T>

where M: PartialEq, H: PartialEq, T: PartialEq,

fn eq(&self, other: &ChainedHandler<M, H, T>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<M, H, T> StructuralPartialEq for ChainedHandler<M, H, T>

where M: PartialEq, H: PartialEq, T: PartialEq,