[−][src]Struct nakadion::consumer::ConsumerHandle
A handle for controlling a Consumer from externally.
Implementations
impl ConsumerHandle[src]
pub fn stop(&self)[src]
Stops the Consumer.
The returned ConsumptionOutcome will contain
ConsumerAbort::UserInitiated as the reason stopping
the Consumer
pub fn stop_requested(&self) -> bool[src]
Returns true if the consumer is stopped or stopping the consumer was requested.
Auto Trait Implementations
impl !RefUnwindSafe for ConsumerHandle
impl Send for ConsumerHandle
impl Sync for ConsumerHandle
impl Unpin for ConsumerHandle
impl !UnwindSafe for ConsumerHandle
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,