Struct rtlola_hir::hir::selector::StreamSelector

pub struct StreamSelector<'a, M: HirMode + TypedTrait, S: Selectable> { /* private fields */ }

A StreamSelector combines different selectors to extract specific stream classes from the Hir. It captures a subset of output streams, where each stream matches all selectors of the StreamSelector.

Implementations

impl<'a, M: HirMode + TypedTrait, S: Selectable> StreamSelector<'a, M, S>

pub fn filtered(self) -> Self

Selects streams with a filter condition.

pub fn unfiltered(self) -> Self

Selects streams without a filter condition.

pub fn filter(self, selector: FilterSelector) -> Self

Selects streams with the filter behaviour specified by the FilterSelector.

pub fn periodic_eval(self) -> Self

Selects streams with periodic evaluation pacing.

pub fn event_based_eval(self) -> Self

Selects streams with event-based evaluation pacing.

pub fn eval(self, selector: PacingSelector) -> Self

Selects streams with an evaluation pacing matching the PacingSelector.

pub fn build(self) -> impl Iterator<Item = &'a Output>

Construct the represented subset of output streams matching the given selections.

impl<'a, M: HirMode + TypedTrait> StreamSelector<'a, M, All>

pub fn all(hir: &'a RtLolaHir<M>) -> Self

Creates a new StreamSelector matching all output streams.

pub fn static_streams(self) -> StreamSelector<'a, M, Static>

Selects statically created streams. I.e. only streams without a spawn condition.

pub fn dynamic_streams(self) -> StreamSelector<'a, M, Dynamic>

Selects dynamically created streams. I.e. only streams with a spawn condition.

impl<'a, M: HirMode + TypedTrait> StreamSelector<'a, M, Dynamic>

pub fn periodic_spawn(self) -> Self

Selects streams with a periodic spawn pacing.

pub fn event_based_spawn(self) -> Self

Selects streams with a event-based spawn pacing.

pub fn spawn(self, selector: PacingSelector) -> Self

Selects streams with a spawn pacing matching the PacingSelector.

pub fn close(self, selector: CloseSelector) -> Self

Selects streams with a closing behaviour matching the CloseSelector

pub fn parameterized(self) -> Self

Selects streams with parameters

pub fn not_parameterized(self) -> Self

Selects streams without parameters

pub fn parameters(self, selector: ParameterSelector) -> Self

Selects streams with a parameter configuration matching the ParameterSelector

Trait Implementations

impl<'a, M: Clone + HirMode + TypedTrait, S: Clone + Selectable> Clone for StreamSelector<'a, M, S>

fn clone(&self) -> StreamSelector<'a, M, S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a, M: Debug + HirMode + TypedTrait, S: Debug + Selectable> Debug for StreamSelector<'a, M, S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a, M: Copy + HirMode + TypedTrait, S: Copy + Selectable> Copy for StreamSelector<'a, M, S>