Trait StreamingPredict 

pub trait StreamingPredict<S, Output> {
    type Error: Error + Send + Sync;

    // Required method
    fn predict_stream<'a>(
        &'a self,
        stream: S,
    ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>
       where S: Stream + Send + 'a;
}

Trait for streaming predictions

Required Associated Types

type Error: Error + Send + Sync

Required Methods

fn predict_stream<'a>( &'a self, stream: S, ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>

where S: Stream + Send + 'a,

Make predictions on streaming data

Implementors