Struct PerStream 

#[repr(transparent)]
pub struct PerStream<T>(pub [T; 11]);

One T per preprocessing stream, indexed by PreprocessingKind.

Tuple Fields

0: [T; 11]

Implementations

impl<T> PerStream<T>

pub fn from_fn(f: impl FnMut(PreprocessingKind) -> T) -> Self

Builds each slot from its kind.

pub fn uniform(value: T) -> Self

where T: Clone,

The same value for every stream.

pub fn with(self, kind: PreprocessingKind, value: T) -> Self

Overrides one slot.

pub fn iter(&self) -> impl Iterator<Item = &T>

Every slot, in PreprocessingKind::ALL order.

pub fn componentwise_max(self, other: Self) -> Self

where T: Ord + Copy,

Slot-wise maximum.

Trait Implementations

impl<T: AddAssign + Copy> Add for PerStream<T>

type Output = PerStream<T>

The resulting type after applying the + operator.

fn add(self, rhs: Self) -> Self

Performs the + operation.

impl<T: AddAssign + Copy> AddAssign for PerStream<T>

fn add_assign(&mut self, rhs: Self)

Performs the += operation.

impl Buffer for PerStream<SharedBufferConfig>

Writes apply to every stream; reads return the first.

fn config(&self) -> &SharedBufferConfig

The shared configuration handle.

fn set_capacity(&self, capacity: usize) -> Result<(), CorrelatedStreamError>

fn set_max_request_size(&self, n: usize) -> Result<(), CorrelatedStreamError>

fn set_refill_threshold(&self, n: usize) -> Result<(), CorrelatedStreamError>

fn capacity(&self) -> Result<usize, CorrelatedStreamError>

fn max_request_size(&self) -> Result<usize, CorrelatedStreamError>

fn refill_threshold(&self) -> Result<usize, CorrelatedStreamError>

impl<T: Clone> Clone for PerStream<T>

fn clone(&self) -> PerStream<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Copy> Copy for PerStream<T>

impl<T: Debug> Debug for PerStream<T>

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

Formats the value using the given formatter.

impl<T: Default> Default for PerStream<T>

fn default() -> PerStream<T>

Returns the “default value” for a type.

impl<'de, T> Deserialize<'de> for PerStream<T>

where T: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: Eq> Eq for PerStream<T>

impl<T> Index<PreprocessingKind> for PerStream<T>

type Output = T

The returned type after indexing.

fn index(&self, kind: PreprocessingKind) -> &T

Performs the indexing (container[index]) operation.

impl<T> IndexMut<PreprocessingKind> for PerStream<T>

fn index_mut(&mut self, kind: PreprocessingKind) -> &mut T

Performs the mutable indexing (container[index]) operation.

impl<T: PartialEq> PartialEq for PerStream<T>

fn eq(&self, other: &PerStream<T>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<T> Serialize for PerStream<T>

where T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T: PartialEq> StructuralPartialEq for PerStream<T>

impl<T: SubAssign + Copy> Sub for PerStream<T>

type Output = PerStream<T>

The resulting type after applying the - operator.

fn sub(self, rhs: Self) -> Self

Performs the - operation.

impl<T: SubAssign + Copy> SubAssign for PerStream<T>

fn sub_assign(&mut self, rhs: Self)

Performs the -= operation.