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

CommandWaitNotifier

Interface for notifying command wait endpoints about processing results. After command processors complete their work, they send results to waiting clients through implementations of this interface.

Author

Ahoo Wang

Inheritors

LocalCommandWaitNotifier

Functions

notify

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

Sends a wait signal notification to the specified command wait endpoint.

notifyAndForget

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

Sends a wait signal notification asynchronously without waiting for completion. Uses bounded elastic scheduler to avoid blocking the calling thread.

notifyAndForget

fun CommandWaitNotifier.notifyAndForget(waiteStrategy: ExtractedWaitStrategy, waitSignal: WaitSignal)

Extension function to notify and forget using an extracted wait strategy. Only sends notification if the wait strategy should be notified for this signal.