EventProcessor

val app = launchApplication(...) {
     eventDispatcher {
         coroutineContext = context1 // 配置事件调度器的统一上下文
     }
}

app.eventDispatcher.register { context ->
    withContext(context2) { // 在事件处理逻辑内切换上下文
         // ...
    }
    EventResult.empty()
}

val flow = app.eventDispatcher.push(event)
    // 上游的逻辑会通过 flowOn 运行在 context1 中
    .onEach { ... } // 会切换到 context3 上
    .flowOn(context3) // 将上游调度器切换至 context3
    .onEach { ... } // 会在 collect 所在的默认（当前）环境中
    .collect { ... } // 在默认（当前）环境收集结果

List<EventResult> resultList = EventProcessors.pushAndCollectToListAsync(processor, event, scope);
// ...

Flux<EventResult> resultList = EventProcessors.pushAndAsFlux(processor, event, scope);
// ...