wow-core/me.ahoo.wow.command.wait/LocalCommandWaitNotifier

LocalCommandWaitNotifier

class LocalCommandWaitNotifier(waitCoordinator: WaitCoordinator) : CommandWaitNotifier

Local implementation of CommandWaitNotifier for in-process notifications. This notifier forwards wait signals to registered wait handles within the same JVM instance.

Parameters

waitCoordinator

The coordinator containing active wait handles.

Constructors

LocalCommandWaitNotifier

constructor(waitCoordinator: WaitCoordinator)

Types

Companion

object Companion

Functions

notify

open override fun notify(commandWaitEndpoint: String, waitSignal: WaitSignal): Mono<Void>

Notifies local wait handles if the signal belongs to this JVM instance. Uses the wait coordinator to forward signals to waiting clients.

notifyAndForget

open override fun notifyAndForget(commandWaitEndpoint: String, waitSignal: WaitSignal)

Local notification completes synchronously, so the fire-and-forget path skips the per-signal Mono.fromRunnable and subscriber allocations of the default implementation. Notification failures are logged instead of propagating to the notifying pipeline, matching the dropped-error semantics of notify(...).subscribe().