Skip to content

Source snapshot · 12 October 2026

API reference / ravet_device::GraphEventConsumer

Struct GraphEventConsumer

pub struct GraphEventConsumer { /* private fields */ }

Expand description

Unique consumer with preallocated retained batch storage. A borrowed batch stays pending until explicit acknowledgement; dropping its borrow does not imply delivery or discard. Endpoints/storage drop after owners stop.

Implementations§

impl GraphEventConsumer

pub fn next_batch(&mut self) -> Option<GraphEventBatch<'_>>

Return the retained batch, or dequeue one atomically published batch. No pending batch is replaced; caller acknowledges only after consuming or explicitly discarding it under its own graph fault/recovery policy.

pub fn producer_disconnected(&self) -> bool

Producer teardown does not discard any retained/queued batches.

Auto Trait Implementations§

impl !Freeze for GraphEventConsumer

impl !RefUnwindSafe for GraphEventConsumer

impl !Sync for GraphEventConsumer

impl Send for GraphEventConsumer

impl Unpin for GraphEventConsumer

impl UnsafeUnpin for GraphEventConsumer

impl UnwindSafe for GraphEventConsumer

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> AutoreleaseSafe for T
where T: ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<S, T> Duplex<S> for Twhere T: FromSample<S> + ToSample<S>,

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<S> FromSample<S> for S

fn from_sample_(s: S) -> S

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<F, T> IntoSample<T> for Fwhere T: FromSample<F>,

fn into_sample(self) -> T

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> ToSample<U> for Twhere U: FromSample<T>,

fn to_sample_(self) -> U

impl<T, U> TryFrom<U> for T
where 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>

Performs the conversion.

impl<T, U> TryInto<U> for T
where 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>

Performs the conversion.