| commit | eb7fb927143902dda2870e0654e14213c793f54b | [log] [tgz] |
|---|---|---|
| author | Benoit Tellier <btellier@linagora.com> | Sat May 15 08:39:44 2021 +0700 |
| committer | Tellier Benoit <btellier@linagora.com> | Sat May 15 12:50:51 2021 +0700 |
| tree | 63f71e0700ed4d1a4cd952230fdf06808ca77e94 | |
| parent | 1554adbf5e0926e40c147d57042b582c90ec240c [diff] |
[FIX] Solve build issue (TaskManagerContract::awaitShouldAwaitWaitingTask)
diff --git a/event-sourcing/event-sourcing-core/src/main/scala/org/apache/james/eventsourcing/EventBus.scala b/event-sourcing/event-sourcing-core/src/main/scala/org/apache/james/eventsourcing/EventBus.scala index e932252..f6ebd52 100644 --- a/event-sourcing/event-sourcing-core/src/main/scala/org/apache/james/eventsourcing/EventBus.scala +++ b/event-sourcing/event-sourcing-core/src/main/scala/org/apache/james/eventsourcing/EventBus.scala
@@ -36,7 +36,7 @@ def runHandlers(events: Iterable[Event], subscribers: Set[Subscriber]): SMono[Void] = SFlux.fromIterable(events.flatMap((event: Event) => subscribers.map(subscriber => (event, subscriber)))) - .flatMapSequential(infos => runHandler(infos._1, infos._2)) + .concatMap(infos => runHandler(infos._1, infos._2)) .`then`() .`then`(SMono.empty)