Trait WriteListener 

pub trait WriteListener<O>: Send + Sync {
    // Provided methods
    fn before_write<'a>(
        &'a self,
        outputs: &'a [O],
        context: ItemListenerContext<'a>,
    ) -> BoxFuture<'a, Result<(), ListenerError>> { ... }
    fn after_write<'a>(
        &'a self,
        outputs: &'a [O],
        context: ItemListenerContext<'a>,
    ) -> BoxFuture<'a, Result<(), ListenerError>> { ... }
    fn on_write_error<'a>(
        &'a self,
        outputs: &'a [O],
        fault: FaultDescriptor,
        context: ItemListenerContext<'a>,
    ) -> BoxFuture<'a, Result<(), ListenerError>> { ... }
}

Observes writer invocations for one output batch.

Provided Methods

fn before_write<'a>( &'a self, outputs: &'a [O], context: ItemListenerContext<'a>, ) -> BoxFuture<'a, Result<(), ListenerError>>

Runs in registration order before the writer is invoked.

fn after_write<'a>( &'a self, outputs: &'a [O], context: ItemListenerContext<'a>, ) -> BoxFuture<'a, Result<(), ListenerError>>

Runs in reverse registration order after the batch is accepted.

fn on_write_error<'a>( &'a self, outputs: &'a [O], fault: FaultDescriptor, context: ItemListenerContext<'a>, ) -> BoxFuture<'a, Result<(), ListenerError>>

Runs in reverse registration order for every failed writer call.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors