Processor

Base interface for implementations that process RuntimeEvent.

Inheritors

Functions

Link copied to clipboard
abstract fun clearObservers()
Link copied to clipboard
@JvmStatic
fun RuntimeEvent.Processor.observeSignalNewNym(tag: String?, executor: OnEvent.Executor?, onEvent: OnEvent<String?>): Disposable.Once

Subscribes with provided TorRuntime a CMD observer which will intercept execution of all TorCmd.Signal.NewNym jobs in order to transform tor's generic server response of Reply.Success.OK.

Link copied to clipboard
abstract fun subscribe(observer: RuntimeEvent.Observer<*>)

Add a single Observer.

abstract fun subscribe(vararg observers: RuntimeEvent.Observer<*>)

Add multiple Observer.

abstract fun subscribe(observer: TorEvent.Observer)
abstract fun subscribe(vararg observers: TorEvent.Observer)
Link copied to clipboard
abstract fun unsubscribe(observer: RuntimeEvent.Observer<*>)

Remove a single Observer.

abstract fun unsubscribe(vararg observers: RuntimeEvent.Observer<*>)

Remove multiple Observer.

abstract fun unsubscribe(observer: TorEvent.Observer)
abstract fun unsubscribe(vararg observers: TorEvent.Observer)
Link copied to clipboard
abstract fun unsubscribeAll(event: RuntimeEvent<*>)

Remove all Observer of a single RuntimeEvent.

abstract fun unsubscribeAll(vararg events: RuntimeEvent<*>)

Remove all Observer of multiple RuntimeEvent.

abstract fun unsubscribeAll(event: TorEvent)
abstract fun unsubscribeAll(vararg events: TorEvent)
abstract fun unsubscribeAll(tag: String)