dfir_lang/graph/ops/
all_once.rs

1use super::{FloType, OperatorCategory, OperatorConstraints, IDENTITY_WRITE_FN, RANGE_0, RANGE_1};
2
3/// Given a _bounded_ input stream, emits the entire stream in the first loop iteration.
4///
5/// Never causes additional loop iterations.
6pub const ALL_ONCE: OperatorConstraints = OperatorConstraints {
7    name: "all_once",
8    categories: &[OperatorCategory::Windowing],
9    hard_range_inn: RANGE_1,
10    soft_range_inn: RANGE_1,
11    hard_range_out: RANGE_1,
12    soft_range_out: RANGE_1,
13    num_args: 0,
14    persistence_args: RANGE_0,
15    type_args: RANGE_0,
16    is_external_input: false,
17    has_singleton_output: true,
18    flo_type: Some(FloType::Windowing),
19    ports_inn: None,
20    ports_out: None,
21    input_delaytype_fn: |_| None,
22    write_fn: IDENTITY_WRITE_FN,
23};