com.hcl.domino.keep.eventbus

Class KeepSubscriber

java.lang.Object

com.hcl.domino.keep.eventbus.KeepSubscriber

All Implemented Interfaces:

KeepSubscriberInfo, io.reactivex.Emitter<io.vertx.core.json.JsonObject>, io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>

public abstract class KeepSubscriber
extends java.lang.Object
implements io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>, KeepSubscriberInfo

Shortcut object for ObservableEmitter to handle the methods we usually don’t implement

Field Summary

Fields

Modifier and Type	Field and Description
protected io.reactivex.functions.Cancellable	c
protected io.reactivex.disposables.Disposable	d

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	KeepSubscriber(java.lang.String apiName, KeepUser user) A KeepSubscriber always carries API Name and Domino User

Method Summary

Modifier and Type	Method and Description
java.lang.String	getApiName()
KeepUser	getUser()
boolean	isDisposed()
io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>	serialize()
void	setCancellable(io.reactivex.functions.Cancellable c)
void	setDisposable(io.reactivex.disposables.Disposable d)
boolean	tryOnError(java.lang.Throwable t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.reactivex.Emitter

onComplete, onError, onNext

Field Detail

d

protected io.reactivex.disposables.Disposable d

c

protected io.reactivex.functions.Cancellable c

Constructor Detail

KeepSubscriber

protected KeepSubscriber(java.lang.String apiName,
                         KeepUser user)

A KeepSubscriber always carries API Name and Domino User

Parameters:

apiName -

user -

Method Detail

getApiName

public java.lang.String getApiName()

Specified by:

getApiName in interface KeepSubscriberInfo

Returns:

the API Name of the database in use

getUser

public KeepUser getUser()

Specified by:

getUser in interface KeepSubscriberInfo

Returns:

the current Domino User

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>

serialize

public io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject> serialize()

Specified by:

serialize in interface io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>

setCancellable

public void setCancellable(io.reactivex.functions.Cancellable c)

Specified by:

setCancellable in interface io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>

setDisposable

public void setDisposable(io.reactivex.disposables.Disposable d)

Specified by:

setDisposable in interface io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>

tryOnError

public boolean tryOnError(java.lang.Throwable t)

Specified by:

tryOnError in interface io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>