Skip to main content

StreamTransform

Trait StreamTransform 

Source
pub trait StreamTransform: Send + Sync {
    // Required method
    fn apply(&self, input: EventStream, ctx: TransformContext) -> EventStream;
}
Expand description

A stream transform.

Implemented for every Fn(EventStream, TransformContext) -> EventStream closure.

Required Methods§

Source

fn apply(&self, input: EventStream, ctx: TransformContext) -> EventStream

Wraps input.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§