Struct hydro_lang::location::process::Process

pub struct Process<'a, P = ()> { /* private fields */ }

Trait Implementations

impl<'a, P1, C2> CanSend<'a, Cluster<'a, C2>> for Process<'a, P1>

type In<T> = (ClusterId<C2>, T)

type Out<T> = T

type OutStrongestOrder<InOrder> = InOrder

Given the ordering guarantees of the input, determines the strongest possible ordering guarantees of the output.

fn is_demux() -> bool

fn tagged_type() -> Option<Type>

impl<'a, P1, E2> CanSend<'a, ExternalProcess<'a, E2>> for Process<'a, P1>

type In<T> = T

type Out<T> = T

type OutStrongestOrder<InOrder> = InOrder

Given the ordering guarantees of the input, determines the strongest possible ordering guarantees of the output.

fn is_demux() -> bool

fn tagged_type() -> Option<Type>

impl<'a, C1, P2> CanSend<'a, Process<'a, P2>> for Cluster<'a, C1>

type In<T> = T

type Out<T> = (ClusterId<C1>, T)

type OutStrongestOrder<InOrder> = NoOrder

Given the ordering guarantees of the input, determines the strongest possible ordering guarantees of the output.

fn is_demux() -> bool

fn tagged_type() -> Option<Type>

impl<'a, P1, P2> CanSend<'a, Process<'a, P2>> for Process<'a, P1>

type In<T> = T

type Out<T> = T

type OutStrongestOrder<InOrder> = InOrder

Given the ordering guarantees of the input, determines the strongest possible ordering guarantees of the output.

fn is_demux() -> bool

fn tagged_type() -> Option<Type>

impl<P> Clone for Process<'_, P>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a, P> Location<'a> for Process<'a, P>

type Root = Process<'a, P>

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>

where Self: Sized + NoTick,

fn source_stream<T, E: FuturesStream<Item = T> + Unpin>( &self, e: impl QuotedWithContext<'a, E, Self>, ) -> Stream<T, Self, Unbounded>

where Self: Sized + NoTick,

fn source_iter<T, E: IntoIterator<Item = T>>( &self, e: impl QuotedWithContext<'a, E, Self>, ) -> Stream<T, Self, Unbounded>

where Self: Sized + NoTick,

fn singleton<T: Clone>( &self, e: impl QuotedWithContext<'a, T, Self>, ) -> Singleton<T, Self, Unbounded>

where Self: Sized + NoTick,

unsafe fn source_interval( &self, interval: impl QuotedWithContext<'a, Duration, Self> + Copy + 'a, ) -> Stream<Instant, Self, Unbounded>

where Self: Sized + NoTick,

Generates a stream with values emitted at a fixed interval, with each value being the current time (as an [tokio::time::Instant]).

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>

where Self: Sized + NoTick,

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

fn forward_ref<S: CycleCollection<'a, ForwardRefMarker, Location = Self>>( &self, ) -> (ForwardRef<'a, S>, S)

where Self: NoTick,

impl<T> NoTick for Process<'_, T>

impl<T> NoTimestamp for Process<'_, T>