wow-elasticsearch/me.ahoo.wow.elasticsearch/IndexTemplateInitializer/InitSubscriber

InitSubscriber

class InitSubscriber(val name: String) : SafeSubscriber<Boolean>

Constructors

constructor(name: String)

Properties

open override val isDisposed: Boolean

open override val name: String

Functions

fun cancel()

open fun currentContext(): Context?

open fun dispose()

fun onComplete()

fun onError(t: Throwable?)

fun onNext(value: Boolean?)

fun onSubscribe(s: Subscription?)

fun request(n: Long)

requestUnbounded

fun requestUnbounded()

open fun safeOnNext(value: Boolean)

safeOnNextError

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