FiniteAnalyzerLoop

class FiniteAnalyzerLoop<DataFrame, State, Output>(analyzerPool: AnalyzerPool<DataFrame, in State, Output>, resultHandler: TerminatingResultHandler<DataFrame, out State, Output>, analyzerLoopErrorListener: AnalyzerLoopErrorListener, timeLimit: Duration = Duration.INFINITE, statsName: String? = null) : AnalyzerLoop<DataFrame, State, Output>

This kind of AnalyzerLoop will process data provided as part of its constructor. Data will be processed in the order provided.

Parameters

analyzerPool

: A pool of analyzers to use in this loop.

resultHandler

: A result handler that will be called with the results from the analyzers in this loop.

analyzerLoopErrorListener

: An error handler for this loop

timeLimit

: If specified, this is the maximum allowed time for the loop to run. If the loop exceeds this duration, the loop will terminate

Constructors

Link copied to clipboard
constructor(analyzerPool: AnalyzerPool<DataFrame, in State, Output>, resultHandler: TerminatingResultHandler<DataFrame, out State, Output>, analyzerLoopErrorListener: AnalyzerLoopErrorListener, timeLimit: Duration = Duration.INFINITE, statsName: String? = null)

Functions

Link copied to clipboard
fun cancel()
Link copied to clipboard
open override fun getState(): State
Link copied to clipboard
open suspend override fun onResult(result: Output, data: DataFrame): Boolean
Link copied to clipboard
fun process(frames: Collection<DataFrame>, processingCoroutineScope: CoroutineScope): Job?