Struct Selector 

pub struct Selector { /* private fields */ }

Selector filters the stream to include only relevant frames typically matching a specific JSON path (e.g., “choices.0.delta”)

Implementations

impl Selector

pub fn new(path: String) -> Self

Trait Implementations

impl Transform for Selector

fn transform<'life0, 'async_trait>( &'life0 self, input: BoxStream<'static, Value>, ) -> Pin<Box<dyn Future<Output = PipeResult<BoxStream<'static, Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

A transform takes a stream of JSON values and returns a new stream of JSON values