Trait AckHandler

pub trait AckHandler: Stream<Item = Result<Self::Output, Self::Error>> + Unpin {
    type Output;
    type Error: Error + Send + Sync + 'static;
}

Produces a stream of acknowledgments from an associated Publisher or Subscriber.

Required Associated Types

type Output

The type of output that the acknowledhment handler will produce when it fails.

type Error: Error + Send + Sync + 'static

The type of Error that the acknowledgment handler will produce when it fails.

Implementors