Struct hydro_lang::location::tick::Timestamped
source · pub struct Timestamped<L> { /* private fields */ }Trait Implementations§
source§impl<L: Clone> Clone for Timestamped<L>
impl<L: Clone> Clone for Timestamped<L>
source§fn clone(&self) -> Timestamped<L>
fn clone(&self) -> Timestamped<L>
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl<'a, L: Location<'a>> Location<'a> for Timestamped<L>
impl<'a, L: Location<'a>> Location<'a> for Timestamped<L>
type Root = <L as Location<'a>>::Root
fn root(&self) -> Self::Root
fn id(&self) -> LocationId
fn flow_state(&self) -> &FlowState
fn is_top_level() -> bool
fn tick(&self) -> Tick<Self>where
Self: NoTick,
fn spin(&self) -> Stream<(), Self, Unbounded>
fn source_stream<T, E: FuturesStream<Item = T> + Unpin>( &self, e: impl QuotedWithContext<'a, E, Self>, ) -> Stream<T, Self, Unbounded>
fn source_iter<T, E: IntoIterator<Item = T>>( &self, e: impl QuotedWithContext<'a, E, Self>, ) -> Stream<T, Self, Unbounded>
fn singleton<T: Clone>( &self, e: impl QuotedWithContext<'a, T, Self>, ) -> Singleton<T, Self, Unbounded>
source§unsafe fn source_interval(
&self,
interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a,
) -> Stream<Instant, Self, Unbounded>
unsafe fn source_interval( &self, interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a, ) -> Stream<Instant, Self, Unbounded>
Generates a stream with values emitted at a fixed interval, with
each value being the current time (as an [
tokio::time::Instant]). Read moresource§unsafe fn source_interval_delayed(
&self,
delay: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a,
interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a,
) -> Stream<Instant, Self, Unbounded>
unsafe fn source_interval_delayed( &self, delay: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a, interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a, ) -> Stream<Instant, Self, Unbounded>
Generates a stream with values emitted at a fixed interval (with an
initial delay), with each value being the current time
(as an [
tokio::time::Instant]). Read morefn forward_ref<S: CycleCollection<'a, ForwardRefMarker, Location = Self>>(
&self,
) -> (ForwardRef<'a, S>, S)where
Self: NoTick,
impl<L> NoTick for Timestamped<L>
Auto Trait Implementations§
impl<L> Freeze for Timestamped<L>where
L: Freeze,
impl<L> RefUnwindSafe for Timestamped<L>where
L: RefUnwindSafe,
impl<L> Send for Timestamped<L>where
L: Send,
impl<L> Sync for Timestamped<L>where
L: Sync,
impl<L> Unpin for Timestamped<L>where
L: Unpin,
impl<L> UnwindSafe for Timestamped<L>where
L: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit)§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more