FiniteAnalyzerLoop
class FiniteAnalyzerLoop<DataFrame, State, Output>( analyzerPool: AnalyzerPool<DataFrame, in State, Output>, resultHandler: TerminatingResultHandler<DataFrame, out State, Output>, analyzerLoopErrorListener: AnalyzerLoopErrorListener, timeLimit: Duration = Duration.INFINITE) : AnalyzerLoop<DataFrame, State, Output>
Content copied to clipboard
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
fun <DataFrame, State, Output> FiniteAnalyzerLoop( analyzerPool: AnalyzerPool<DataFrame, in State, Output>, resultHandler: TerminatingResultHandler<DataFrame, out State, Output>, analyzerLoopErrorListener: AnalyzerLoopErrorListener, timeLimit: Duration = Duration.INFINITE)
Content copied to clipboard
Functions
Link copied to clipboard
fun process(frames: Collection<DataFrame>, processingCoroutineScope: CoroutineScope): Job?
Content copied to clipboard