AnalyzerLoop

A loop to execute repeated analysis. The loop uses coroutines to run the Analyzer.analyze method. If the Analyzer is threadsafe, multiple coroutines will be used. If not, a single coroutine will be used.

Any data enqueued while the analyzers are at capacity will be dropped.

This will process data until the result aggregator returns true.

Note: an analyzer loop can only be started once. Once it terminates, it cannot be restarted.

Parameters

analyzerPool

: A pool of analyzers to use in this loop.

analyzerLoopErrorListener

: An error handler for this loop

Inheritors

Functions

Link copied to clipboard
abstract fun getState(): State
Link copied to clipboard
abstract suspend fun onResult(result: Output, data: DataFrame): Boolean