pub trait ReadListener<I>: Send + Sync {
// Provided methods
fn before_read<'a>(
&'a self,
context: ItemListenerContext<'a>,
) -> BoxFuture<'a, Result<(), ListenerError>> { ... }
fn after_read<'a>(
&'a self,
item: &'a I,
context: ItemListenerContext<'a>,
) -> BoxFuture<'a, Result<(), ListenerError>> { ... }
fn on_read_error<'a>(
&'a self,
fault: FaultDescriptor,
context: ItemListenerContext<'a>,
) -> BoxFuture<'a, Result<(), ListenerError>> { ... }
}Expand description
Observes reader invocations for one item.
Provided Methods§
Sourcefn before_read<'a>(
&'a self,
context: ItemListenerContext<'a>,
) -> BoxFuture<'a, Result<(), ListenerError>>
fn before_read<'a>( &'a self, context: ItemListenerContext<'a>, ) -> BoxFuture<'a, Result<(), ListenerError>>
Runs in registration order before the reader is invoked.
Sourcefn after_read<'a>(
&'a self,
item: &'a I,
context: ItemListenerContext<'a>,
) -> BoxFuture<'a, Result<(), ListenerError>>
fn after_read<'a>( &'a self, item: &'a I, context: ItemListenerContext<'a>, ) -> BoxFuture<'a, Result<(), ListenerError>>
Runs in reverse registration order after one item is read.
Sourcefn on_read_error<'a>(
&'a self,
fault: FaultDescriptor,
context: ItemListenerContext<'a>,
) -> BoxFuture<'a, Result<(), ListenerError>>
fn on_read_error<'a>( &'a self, fault: FaultDescriptor, context: ItemListenerContext<'a>, ) -> BoxFuture<'a, Result<(), ListenerError>>
Runs in reverse registration order for every failed reader call.
This includes a call that a later retry completes successfully.
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".