Struct nakadion::consumer::ConsumptionOutcome

pub struct ConsumptionOutcome { /* fields omitted */ }

Returned once a Consumer has stopped. It contains the original consumer and a ConsumerAbort which gives more insight on why the consumer was stopped.

Implementations

impl ConsumptionOutcome

pub fn is_user_aborted(&self) -> bool

true if the consumption was aborted by the user via the handle.

pub fn is_error(&self) -> bool

true if the consumption was afrom internally.

pub fn into_consumer(self) -> Consumer

Turn the outcome into the contained Consumer

pub fn try_into_err(self) -> Result<ConsumerError, Self>

If there was an error return the error as OK otherwise return self as an error.

pub fn into_reason(self) -> ConsumerAbort

Turns this into the reason loosing the consumer

pub fn as_reason(&self) -> &ConsumerAbort

pub fn spilt(self) -> (Consumer, ConsumerAbort)

Split this outcome into the Consumer and the reason.

pub fn error(&self) -> Option<&ConsumerError>

If there was an error return a reference to it.

pub fn into_result(self) -> Result<Consumer, ConsumerError>

Turn this outcome into a Result.

If there was an error the Err case will contain the error. Otherwise the OK case will contain the Consumer´. If there was an error the Consumer` will be lost.