Skip to main content

DataAvailableStream

zerodds_dcps_async

Struct DataAvailableStream

pub struct DataAvailableStream<T: DdsType + Send + Sync + 'static> { /* private fields */ }

Expand description

Stream der “data available”-Events. Yieldet () jedes Mal wenn neue Samples im Reader sind. Konsumiert keine Samples — Caller muss take() oder take_stream separat aufrufen.

Trait Implementations§

impl<T: DdsType + Send + Sync + 'static> Stream for DataAvailableStream<T>

type Item = ()

Values yielded by the stream.

fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<()>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted. Read more

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream. Read more

impl<T: DdsType + Send + Sync + 'static> Unpin for DataAvailableStream<T>

Auto Trait Implementations§

impl<T> Freeze for DataAvailableStream<T>

impl<T> !RefUnwindSafe for DataAvailableStream<T>

impl<T> Send for DataAvailableStream<T>

impl<T> Sync for DataAvailableStream<T>

impl<T> UnsafeUnpin for DataAvailableStream<T>

impl<T> !UnwindSafe for DataAvailableStream<T>

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> 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<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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<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.