Trait StreamSplitCodec 

pub trait StreamSplitCodec: Send + Sync {
    // Required method
    fn split(
        &self,
        input: StreamSplitInput,
        config: StreamSplitConfig,
    ) -> Pin<Box<dyn Stream<Item = Result<Exchange, CamelError>> + Send>>;
}

Required Methods

fn split( &self, input: StreamSplitInput, config: StreamSplitConfig, ) -> Pin<Box<dyn Stream<Item = Result<Exchange, CamelError>> + Send>>

Dyn Compatibility

This trait is dyn compatible.

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

Implementors

impl StreamSplitCodec for ChunksCodec

impl StreamSplitCodec for LinesCodec

impl StreamSplitCodec for NdjsonCodec