pub struct Atomic<Loc> { /* private fields */ }Trait Implementations§
Source§impl<'a, L> Location<'a> for Atomic<L>where
L: Location<'a>,
impl<'a, L> Location<'a> for Atomic<L>where
L: Location<'a>,
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, TotalOrder, ExactlyOnce>
fn source_stream<T, E>( &self, e: impl QuotedWithContext<'a, E, Self>, ) -> Stream<T, Self, Unbounded, TotalOrder, ExactlyOnce>
fn source_iter<T, E>( &self, e: impl QuotedWithContext<'a, E, Self>, ) -> Stream<T, Self, Unbounded, TotalOrder, ExactlyOnce>
fn source_cluster_members<C: 'a>( &self, cluster: &Cluster<'a, C>, ) -> KeyedStream<MemberId<C>, MembershipEvent, Self, Unbounded>
fn source_external_bytes<L>( &self, from: &External<'_, L>, ) -> (ExternalBytesPort, Stream<Result<BytesMut>, Self, Unbounded, TotalOrder, ExactlyOnce>)
fn source_external_bincode<L, T>( &self, from: &External<'_, L>, ) -> (ExternalBincodeSink<T>, Stream<T, Self, Unbounded, TotalOrder, ExactlyOnce>)
fn bidi_external_many_bytes<L, T, Codec: Encoder<T> + Decoder>( &self, from: &External<'_, L>, port_hint: NetworkHint, ) -> (ExternalBytesPort<Many>, KeyedStream<u64, <Codec as Decoder>::Item, Self, Unbounded, TotalOrder, ExactlyOnce>, KeyedStream<u64, MembershipEvent, Self, Unbounded, TotalOrder, ExactlyOnce>, ForwardRef<'a, KeyedStream<u64, T, Self, Unbounded, NoOrder, ExactlyOnce>>)
fn bidi_external_many_bincode<L, InT: DeserializeOwned, OutT: Serialize>( &self, from: &External<'_, L>, ) -> (ExternalBincodeBidi<InT, OutT, Many>, KeyedStream<u64, InT, Self, Unbounded, TotalOrder, ExactlyOnce>, KeyedStream<u64, MembershipEvent, Self, Unbounded, TotalOrder, ExactlyOnce>, ForwardRef<'a, KeyedStream<u64, OutT, Self, Unbounded, NoOrder, ExactlyOnce>>)
fn singleton<T>( &self, e: impl QuotedWithContext<'a, T, Self>, ) -> Singleton<T, Self, Unbounded>
Source§fn source_interval(
&self,
interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a,
_nondet: NonDet,
) -> Stream<Instant, Self, Unbounded, TotalOrder, ExactlyOnce>
fn source_interval( &self, interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a, _nondet: NonDet, ) -> Stream<Instant, Self, Unbounded, TotalOrder, ExactlyOnce>
Generates a stream with values emitted at a fixed interval, with
each value being the current time (as an [
tokio::time::Instant]). Read moreSource§fn source_interval_delayed(
&self,
delay: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a,
interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a,
_nondet: NonDet,
) -> Stream<Instant, Self, Unbounded, TotalOrder, ExactlyOnce>
fn source_interval_delayed( &self, delay: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a, interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a, _nondet: NonDet, ) -> Stream<Instant, Self, Unbounded, TotalOrder, ExactlyOnce>
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>(&self) -> (ForwardRef<'a, S>, S)
impl<L> NoTick for Atomic<L>
Auto Trait Implementations§
impl<Loc> Freeze for Atomic<Loc>where
Loc: Freeze,
impl<Loc> RefUnwindSafe for Atomic<Loc>where
Loc: RefUnwindSafe,
impl<Loc> Send for Atomic<Loc>where
Loc: Send,
impl<Loc> Sync for Atomic<Loc>where
Loc: Sync,
impl<Loc> Unpin for Atomic<Loc>where
Loc: Unpin,
impl<Loc> UnwindSafe for Atomic<Loc>where
Loc: 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