pushAndCollectToAsync
fun <C : MutableCollection<in EventResult>> EventProcessor.pushAndCollectToAsync(event: Event, scope: CoroutineScope, collection: C): CompletableFuture<C>(source)
推送事件并将结果收集为 C 后返回 CompletableFuture.
fun <R> EventProcessor.pushAndCollectToAsync(event: Event, scope: CoroutineScope, collector: Collector<EventResult, *, R>): CompletableFuture<R>(source)
推送事件并将结果使用 Collector 收集为 R 后返回 CompletableFuture.