Struct MovingAverageTransformer 

pub struct MovingAverageTransformer { /* private fields */ }

A stateful transformer that calculates a moving average over a sliding window.

Example

use streamweave::transformers::moving_average::MovingAverageTransformer;
use streamweave::transformer::Transformer;
use futures::StreamExt;

let mut transformer = MovingAverageTransformer::new(3); // 3-item window
let input = Box::pin(futures::stream::iter(vec![1.0, 2.0, 3.0, 4.0, 5.0]));
let output = transformer.transform(input);
let results: Vec<f64> = output.collect().await;
// Window: [1] -> avg 1.0
// Window: [1,2] -> avg 1.5
// Window: [1,2,3] -> avg 2.0
// Window: [2,3,4] -> avg 3.0
// Window: [3,4,5] -> avg 4.0
assert_eq!(results, vec![1.0, 1.5, 2.0, 3.0, 4.0]);

Implementations

impl MovingAverageTransformer

pub fn new(window_size: usize) -> Self

Creates a new MovingAverageTransformer with the specified window size.

Arguments

• window_size - The number of recent items to include in the average.

Panics

Panics if window_size is 0.

pub fn with_name(self, name: String) -> Self

Sets the name for this transformer.

pub fn with_error_strategy(self, strategy: ErrorStrategy<f64>) -> Self

Sets the error strategy for this transformer.

pub fn window_size(&self) -> usize

Returns the window size.

Trait Implementations

impl Clone for MovingAverageTransformer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MovingAverageTransformer

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

Formats the value using the given formatter.

impl Input for MovingAverageTransformer

type Input = f64

The type of items produced by this input stream.

type InputStream = Pin<Box<dyn Stream<Item = f64> + Send>>

The input stream type that yields items of type Self::Input.

impl Output for MovingAverageTransformer

type Output = f64

The type of items produced by this output stream.

type OutputStream = Pin<Box<dyn Stream<Item = f64> + Send>>

The output stream type that yields items of type Self::Output.

impl StatefulTransformer for MovingAverageTransformer

type State = MovingAverageState

The type of state maintained by this transformer.

type Store = SharedMovingAverageStore

The type of state store used by this transformer.

fn state_store(&self) -> &Self::Store

Get a reference to the state store.

fn state_store_mut(&mut self) -> &mut Self::Store

Get a mutable reference to the state store.

fn state(&self) -> StateResult<Option<Self::State>>

Get the current state value.

fn set_state(&self, state: Self::State) -> StateResult<()>

Set the state to a new value.

fn reset_state(&self) -> StateResult<()>

Reset the state to its initial value.

fn has_state(&self) -> bool

Check if the state has been initialized.

fn update_state<F>(&self, f: F) -> StateResult<Self::State>

where F: FnOnce(Option<Self::State>) -> Self::State + Send + 'static,

Update the state using a closure.

fn state_or_initial(&self) -> Result<Self::State, StateError>

Get the current state or the initial state if not set.

impl Transformer for MovingAverageTransformer

type InputPorts = (f64,)

The input port tuple type for this transformer.

type OutputPorts = (f64,)

The output port tuple type for this transformer.

fn transform(&mut self, input: Self::InputStream) -> Self::OutputStream

Transforms a stream of input items into a stream of output items.

fn set_config_impl(&mut self, config: TransformerConfig<f64>)

Sets the configuration implementation.

fn get_config_impl(&self) -> &TransformerConfig<f64>

Returns a reference to the configuration implementation.

fn get_config_mut_impl(&mut self) -> &mut TransformerConfig<f64>

Returns a mutable reference to the configuration implementation.

fn handle_error(&self, error: &StreamError<f64>) -> ErrorAction

Handles an error that occurred during stream processing.

fn create_error_context(&self, item: Option<f64>) -> ErrorContext<f64>

Creates an error context for error reporting.

fn component_info(&self) -> ComponentInfo

Returns information about the component for error reporting.

fn with_config(&self, config: TransformerConfig<Self::Input>) -> Self

where Self: Sized + Clone,

Creates a new transformer instance with the given configuration.

fn set_config(&mut self, config: TransformerConfig<Self::Input>)

Sets the configuration for this transformer.

fn config(&self) -> &TransformerConfig<Self::Input>

Returns a reference to the transformer’s configuration.

fn config_mut(&mut self) -> &mut TransformerConfig<Self::Input>

Returns a mutable reference to the transformer’s configuration.

fn with_name(self, name: String) -> Self

where Self: Sized,

Sets the name for this transformer.