Struct Then 

pub struct Then<First, Second> { /* private fields */ }

Two middleware stages evaluated from first to second.

Trait Implementations

impl<State, First, Second> BackendPipelineMiddleware<State> for Then<First, Second>

where First: BackendPipelineMiddleware<State>, Second: BackendPipelineMiddleware<State>,

type Error = ChainError<<First as BackendPipelineMiddleware<State>>::Error, <Second as BackendPipelineMiddleware<State>>::Error>

An error which prevents the message from continuing through the pipeline.

async fn backend_asynchronous( &mut self, state: &mut State, message: AsynchronousBackendMessage, ) -> Result<AsynchronousBackendMessage, Self::Error>

Intercepts backend messages in generated AsynchronousBackendMessage phase.

async fn backend_simple( &mut self, state: &mut State, message: SimpleInternalMessage, ) -> Result<SimpleInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleInternalMessage phase.

async fn backend_simple_error( &mut self, state: &mut State, message: SimpleErrorInternalMessage, ) -> Result<SimpleErrorInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleErrorInternalMessage phase.

async fn backend_parse_response( &mut self, state: &mut State, message: ParseResponseInternalMessage, ) -> Result<ParseResponseInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ParseResponseInternalMessage phase.

async fn backend_bind_response( &mut self, state: &mut State, message: BindResponseInternalMessage, ) -> Result<BindResponseInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: BindResponseInternalMessage phase.

async fn backend_describe_response( &mut self, state: &mut State, message: DescribeResponseInternalMessage, ) -> Result<DescribeResponseInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: DescribeResponseInternalMessage phase.

async fn backend_execute_response( &mut self, state: &mut State, message: ExecuteResponseInternalMessage, ) -> Result<ExecuteResponseInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExecuteResponseInternalMessage phase.

async fn backend_close_response( &mut self, state: &mut State, message: CloseResponseInternalMessage, ) -> Result<CloseResponseInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: CloseResponseInternalMessage phase.

async fn backend_sync_response( &mut self, state: &mut State, message: SyncResponseInternalMessage, ) -> Result<SyncResponseInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SyncResponseInternalMessage phase.

async fn backend_function_response( &mut self, state: &mut State, message: FunctionResponseInternalMessage, ) -> Result<FunctionResponseInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: FunctionResponseInternalMessage phase.

async fn backend_function_ready( &mut self, state: &mut State, message: FunctionReadyInternalMessage, ) -> Result<FunctionReadyInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: FunctionReadyInternalMessage phase.

async fn backend_simple_copy_in_done( &mut self, state: &mut State, message: SimpleCopyInDoneInternalMessage, ) -> Result<SimpleCopyInDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyInDoneInternalMessage phase.

async fn backend_simple_copy_in_failed( &mut self, state: &mut State, message: SimpleCopyInFailedInternalMessage, ) -> Result<SimpleCopyInFailedInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyInFailedInternalMessage phase.

async fn backend_simple_copy_out( &mut self, state: &mut State, message: SimpleCopyOutInternalMessage, ) -> Result<SimpleCopyOutInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyOutInternalMessage phase.

async fn backend_simple_copy_out_done( &mut self, state: &mut State, message: SimpleCopyOutDoneInternalMessage, ) -> Result<SimpleCopyOutDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyOutDoneInternalMessage phase.

async fn backend_simple_copy_ready( &mut self, state: &mut State, message: SimpleCopyReadyInternalMessage, ) -> Result<SimpleCopyReadyInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyReadyInternalMessage phase.

async fn backend_extended_copy_in_done( &mut self, state: &mut State, message: ExtendedCopyInDoneInternalMessage, ) -> Result<ExtendedCopyInDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyInDoneInternalMessage phase.

async fn backend_extended_copy_in_failed( &mut self, state: &mut State, message: ExtendedCopyInFailedInternalMessage, ) -> Result<ExtendedCopyInFailedInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyInFailedInternalMessage phase.

async fn backend_extended_copy_out( &mut self, state: &mut State, message: ExtendedCopyOutInternalMessage, ) -> Result<ExtendedCopyOutInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyOutInternalMessage phase.

async fn backend_extended_copy_out_done( &mut self, state: &mut State, message: ExtendedCopyOutDoneInternalMessage, ) -> Result<ExtendedCopyOutDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyOutDoneInternalMessage phase.

async fn backend_simple_copy_both( &mut self, state: &mut State, message: SimpleCopyBothInternalMessage, ) -> Result<SimpleCopyBothInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyBothInternalMessage phase.

async fn backend_simple_copy_both_client_done( &mut self, state: &mut State, message: SimpleCopyBothClientDoneInternalMessage, ) -> Result<SimpleCopyBothClientDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyBothClientDoneInternalMessage phase.

async fn backend_simple_copy_both_done( &mut self, state: &mut State, message: SimpleCopyBothDoneInternalMessage, ) -> Result<SimpleCopyBothDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyBothDoneInternalMessage phase.

async fn backend_simple_copy_both_failed( &mut self, state: &mut State, message: SimpleCopyBothFailedInternalMessage, ) -> Result<SimpleCopyBothFailedInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyBothFailedInternalMessage phase.

async fn backend_extended_copy_both( &mut self, state: &mut State, message: ExtendedCopyBothInternalMessage, ) -> Result<ExtendedCopyBothInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyBothInternalMessage phase.

async fn backend_extended_copy_both_client_done( &mut self, state: &mut State, message: ExtendedCopyBothClientDoneInternalMessage, ) -> Result<ExtendedCopyBothClientDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyBothClientDoneInternalMessage phase.

async fn backend_extended_copy_both_done( &mut self, state: &mut State, message: ExtendedCopyBothDoneInternalMessage, ) -> Result<ExtendedCopyBothDoneInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyBothDoneInternalMessage phase.

async fn backend_extended_copy_both_failed( &mut self, state: &mut State, message: ExtendedCopyBothFailedInternalMessage, ) -> Result<ExtendedCopyBothFailedInternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyBothFailedInternalMessage phase.

impl<First: Clone, Second: Clone> Clone for Then<First, Second>

fn clone(&self) -> Then<First, Second>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<First: Copy, Second: Copy> Copy for Then<First, Second>

impl<First: Debug, Second: Debug> Debug for Then<First, Second>

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

Formats the value using the given formatter.

impl<First: Eq, Second: Eq> Eq for Then<First, Second>

impl<State, First, Second> FrontendPipelineMiddleware<State> for Then<First, Second>

where First: FrontendPipelineMiddleware<State>, Second: FrontendPipelineMiddleware<State>,

type Error = ChainError<<First as FrontendPipelineMiddleware<State>>::Error, <Second as FrontendPipelineMiddleware<State>>::Error>

An error which prevents the message from continuing through the pipeline.

async fn frontend_ready( &mut self, state: &mut State, message: ReadyExternalMessage, ) -> Result<ReadyExternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ReadyExternalMessage phase.

async fn frontend_building( &mut self, state: &mut State, message: BuildingExternalMessage, ) -> Result<BuildingExternalMessage, Self::Error>

Intercepts backend messages in generated backend :: BuildingExternalMessage phase.

async fn frontend_extended_error( &mut self, state: &mut State, message: ExtendedErrorExternalMessage, ) -> Result<ExtendedErrorExternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedErrorExternalMessage phase.

async fn frontend_simple_copy_in( &mut self, state: &mut State, message: SimpleCopyInExternalMessage, ) -> Result<SimpleCopyInExternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyInExternalMessage phase.

async fn frontend_extended_copy_in( &mut self, state: &mut State, message: ExtendedCopyInExternalMessage, ) -> Result<ExtendedCopyInExternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyInExternalMessage phase.

async fn frontend_simple_copy_both( &mut self, state: &mut State, message: SimpleCopyBothExternalMessage, ) -> Result<SimpleCopyBothExternalMessage, Self::Error>

Intercepts backend messages in generated backend :: SimpleCopyBothExternalMessage phase.

async fn frontend_extended_copy_both( &mut self, state: &mut State, message: ExtendedCopyBothExternalMessage, ) -> Result<ExtendedCopyBothExternalMessage, Self::Error>

Intercepts backend messages in generated backend :: ExtendedCopyBothExternalMessage phase.

impl<Message, State, First, Second> MessageMiddleware<Message, State> for Then<First, Second>

where First: MessageMiddleware<Message, State>, Second: MessageMiddleware<Message, State>,

type Error = ChainError<<First as MessageMiddleware<Message, State>>::Error, <Second as MessageMiddleware<Message, State>>::Error>

An error which prevents the message from continuing through the chain.

async fn intercept( &mut self, state: &mut State, message: Message, ) -> Result<Message, Self::Error>

Observes, mutates, or replaces one message and may await external policy, storage, or telemetry work before returning it.

impl<First: PartialEq, Second: PartialEq> PartialEq for Then<First, Second>

fn eq(&self, other: &Then<First, Second>) -> bool

Equality operator ==.

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

Inequality operator !=.

impl<First: PartialEq, Second: PartialEq> StructuralPartialEq for Then<First, Second>

impl<Role, Phase, Message, State, First, Second> TypedMiddleware<Role, Phase, Message, State> for Then<First, Second>

where First: TypedMiddleware<Role, Phase, Message, State>, Second: TypedMiddleware<Role, Phase, Message, State>,

type Error = ChainError<<First as TypedMiddleware<Role, Phase, Message, State>>::Error, <Second as TypedMiddleware<Role, Phase, Message, State>>::Error>

An error which prevents the message from continuing through the chain.

async fn intercept_typed( &mut self, state: &mut State, message: Message, ) -> Result<Message, Self::Error>

Observes, mutates, or replaces one phase-legal message and may await while borrowing both the handler and caller-defined state.