wow-core/me.ahoo.wow.messaging.dispatcher/SafeSubscriber

SafeSubscriber

abstract class SafeSubscriber<T : Any> : BaseSubscriber<T> , Named

A safe subscriber that wraps message processing with error handling.

Extends BaseSubscriber to provide lifecycle hooks with logging and safe error handling for message processing.

Parameters

T

The type of message being subscribed to

Inheritors

DomainEventDistributionSubscriber

StateEventDistributionSubscriber

AbstractMessageDispatcher

AggregateMessageDispatcher

Constructors

constructor()

Types

object Companion

Properties

open override val isDisposed: Boolean

abstract val name: String

Functions

fun cancel()

open fun currentContext(): Context?

open fun dispose()

fun onComplete()

fun onError(t: Throwable?)

fun onNext(value: T?)

fun onSubscribe(s: Subscription?)

fun request(n: Long)

requestUnbounded

fun requestUnbounded()

open fun safeOnNext(value: T)

Safely processes the next message.

safeOnNextError

open fun safeOnNextError(value: T, throwable: Throwable)

Handles errors that occur during message processing.