ty-demeter-blog-3

OperationQueue.kt

internal class OperationQueue(demeter: Demeter, coroutineScope: CoroutineScope) {

    private val queue = Channel<Operation>(BUFFER_SIZE)

    init {
        queue.receiveAsFlow()
            .onEach { operation ->
                runCatching {
                    operation.operate(demeter)
                }.onFailure {
                    demeter.eventResultReporter.report(Result.failure(it))
                }
            }
            .flowOn(Dispatchers.Default)
            .launchIn(coroutineScope)
    }

    fun append(operation: Operation) {
        queue.trySend(operation)
    }
}