Struct AsyncProcessorTraining 

pub struct AsyncProcessorTraining<ET, EV> { /* private fields */ }

Event processor for the training process.

Events are processed on a separate thread. An error an event causes is only known after the call that submitted it has returned and is reported by a later call: process_train, process_valid or flush, whichever comes first. That call returns every failure since the last one it reported, as one EventProcessorError.

Implementations

impl<ET, EV> AsyncProcessorTraining<ET, EV>

where ET: Send + 'static, EV: Send + 'static,

pub fn new<P>(processor: P) -> AsyncProcessorTraining<ET, EV>

where P: EventProcessorTraining<ET, EV> + 'static,

Create an event processor for training.

Trait Implementations

impl<ET, EV> EventProcessorTraining<ET, EV> for AsyncProcessorTraining<ET, EV>

where ET: Send, EV: Send,

fn process_train(&mut self, event: ET) -> Result<(), EventProcessorError>

Collect a training event.

fn process_valid(&mut self, event: EV) -> Result<(), EventProcessorError>

Collect a validation event.

fn flush(&mut self) -> Result<(), EventProcessorError>

Wait until previously submitted events are processed (no-op for sync processors).

fn renderer(self) -> Box<dyn MetricsRenderer>

Returns the renderer used for training.