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

AbstractMessageDispatcher

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

Constructors

AbstractMessageDispatcher

constructor()

Types

object Companion

Properties

abstract val name: String

abstract val topics: Set<Any>

Functions

override fun cancel()

open override fun close()

open fun currentContext(): Context

open override fun dispose()

open override fun isDisposed(): Boolean

override fun onComplete()

override fun onError(p0: Throwable)

override fun onNext(p0: T)

override fun onSubscribe(p0: Subscription)

override fun request(p0: Long)

requestUnbounded

fun requestUnbounded()

open override fun run()

open fun safeOnNext(value: T)

safeOnNextError

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

abstract fun start()