Enum ShutdownBehavior 

pub enum ShutdownBehavior {
    WaitForProcessing,
    NackImmediately,
}

The behavior on shutdown.

Variants

WaitForProcessing

The subscriber stops reading from the underlying gRPC stream.

The subscriber continues to accept acknowledgements for messages it has delivered to the application. The subscriber continues to extend leases for these messages while it waits on the application to ack/nack them.

The shutdown is complete when all message handles delivered to the application have been consumed, and all pending ack/nack RPCs have completed.

NackImmediately

The subscriber stops reading from the underlying gRPC stream.

The subscriber stops accepting acknowledgements from the application. The subscriber sends all pending acknowledgements to the server. The subscriber nacks all other messages under lease management.

The shutdown is complete when all pending ack/nack RPCs have completed.

Trait Implementations

impl Clone for ShutdownBehavior

fn clone(&self) -> ShutdownBehavior

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShutdownBehavior

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

Formats the value using the given formatter.

impl PartialEq for ShutdownBehavior

fn eq(&self, other: &ShutdownBehavior) -> bool

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for ShutdownBehavior

impl StructuralPartialEq for ShutdownBehavior