fun apply()

in Confidence/src/main/java/com/spotify/confidence/apply/EventProcessor.kt [13:23]

• 10 lines of code
• 1 McCabe index (conditional complexity)

    fun apply(input: INPUT)
}

class EventProcessor<INPUT, BatchProcessInputs, DATA>(
    private val onInitialised: suspend () -> DATA,
    private val onApply: (INPUT, DATA) -> Unit,
    private val onProcessBatch:
        (DATA, SendChannel<BatchProcessInputs>, CoroutineScope, CoroutineExceptionHandler) -> Unit,
    private val processBatchAction: (BatchProcessInputs, DATA) -> Unit,
    dispatcher: CoroutineDispatcher
) : EventApplier<INPUT> {