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

AbstractMessageDispatcher

abstract class AbstractMessageDispatcher<T : Any> : SafeSubscriber<T> , MessageDispatcher

Abstract base class for message dispatchers that subscribe to topics.

This class extends SafeSubscriber to handle messages safely and provides lifecycle management for subscribing to and unsubscribing from topics.

Parameters

The type of message being dispatched

Constructors

AbstractMessageDispatcher

constructor()

Types

Companion

object Companion

Properties

isDisposed

open override val isDisposed: Boolean

name

abstract val name: String

topics

abstract val topics: Set<Any>

The set of topics this dispatcher subscribes to.

Functions

cancel

fun cancel()

open override fun close()

Closes the dispatcher by canceling the subscription.

currentContext

open fun currentContext(): Context?

dispose

open fun dispose()

onComplete

fun onComplete()

onError

fun onError(t: Throwable?)

onNext

fun onNext(value: T?)

onSubscribe

fun onSubscribe(s: Subscription?)

request

fun request(n: Long)

requestUnbounded

fun requestUnbounded()

run

open override fun run()

Starts the dispatcher by subscribing to topics.

safeOnNext

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.

start

abstract fun start()

Starts the actual subscription to topics.