pub struct Atomic<L> { /* private fields */ }Trait Implementations§
Source§impl<'a, L: Location<'a>> Location<'a> for Atomic<L>
impl<'a, L: Location<'a>> Location<'a> for Atomic<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 next_node_id(&self) -> usize
fn new_node_metadata<T>(&self) -> HydroIrMetadata
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 Atomic<L>
Auto Trait Implementations§
impl<L> Freeze for Atomic<L>where
L: Freeze,
impl<L> RefUnwindSafe for Atomic<L>where
L: RefUnwindSafe,
impl<L> Send for Atomic<L>where
L: Send,
impl<L> Sync for Atomic<L>where
L: Sync,
impl<L> Unpin for Atomic<L>where
L: Unpin,
impl<L> UnwindSafe for Atomic<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,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> 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