File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed
projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -235,15 +235,15 @@ val user = mediator.send(GetUserQuery("123"))
235235
236236// Notifications now require explicit PublishStrategy (with default)
237237mediator.publish(UserCreatedNotification (user.id)) // Uses default strategy
238- mediator.publish(UserCreatedNotification (user.id), PublishStrategy .PARALLEL_NO_WAIT )
238+ mediator.publish(UserCreatedNotification (user.id), PublishStrategy .CONTINUE_ON_EXCEPTION )
239239```
240240
241241### 5. Update Mediator Creation
242242
243243** Before:**
244244``` kotlin
245245val mediator = MediatorBuilder (dependencyProvider)
246- .withPublishStrategy(ParallelNoWaitPublishStrategy ())
246+ .withPublishStrategy(ContinueOnExceptionPublishStrategy ())
247247 .build()
248248```
249249
Original file line number Diff line number Diff line change @@ -48,7 +48,6 @@ interface Mediator {
4848 *
4949 * @see PublishStrategy.DEFAULT
5050 * @see PublishStrategy.CONTINUE_ON_EXCEPTION
51- * @see PublishStrategy.PARALLEL_NO_WAIT
5251 * @see PublishStrategy.PARALLEL_WHEN_ALL
5352 */
5453 suspend fun <T : Notification > publish (notification : T , publishStrategy : PublishStrategy = PublishStrategy .DEFAULT )
You can’t perform that action at this time.
0 commit comments