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§
Sourcefn apply(&self, input: EventStream, ctx: TransformContext) -> EventStream
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".