com.hcl.domino.keep.eventbus

Class AbstractEventBusResponseSubscriber<T>

java.lang.Object

com.hcl.domino.keep.eventbus.AbstractEventBusResponseSubscriber<T>

Type Parameters:

T - We use JsonObject, JsonArray and Buffer

All Implemented Interfaces:

EventBusResponseSubscriber<T>, KeepSubscriberInfo, io.reactivex.Emitter<T>, io.reactivex.ObservableEmitter<T>, io.reactivex.Observer<T>, java.io.Serializable

Direct Known Subclasses:

EventBusBufferResponseSubscriber, EventBusJsonResponseSubscriber

public abstract class AbstractEventBusResponseSubscriber<T>
extends java.lang.Object
implements EventBusResponseSubscriber<T>

Observer that starts sending back data retrieved from a subscription onto the eventbus

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected io.reactivex.functions.Cancellable	cancellable
protected static org.slf4j.Logger	logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEventBusResponseSubscriber(io.vertx.core.Vertx vertx, io.vertx.core.MultiMap headers, KeepUser user)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getApiName()
java.lang.String	getOperationId()
protected abstract java.util.stream.Collector<T,?,?>	getSendCollector()
KeepUser	getUser()
boolean	isDisposed()
void	onComplete()
void	onError(java.lang.Throwable error)
void	onNext(T data)
void	onSubscribe(io.reactivex.disposables.Disposable d)
io.reactivex.ObservableEmitter<T>	serialize()
void	setAggregateResponses(int aggregateResponses) Sets the batch count of responses to be bundled over the eventbus 0 = no bundling -1 = all (single response)
void	setCacheHeader(java.lang.String cacheKey)
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

Field Detail

logger

protected static final org.slf4j.Logger logger

cancellable

protected transient io.reactivex.functions.Cancellable cancellable

Constructor Detail

AbstractEventBusResponseSubscriber

protected AbstractEventBusResponseSubscriber(@Nonnull
                                             io.vertx.core.Vertx vertx,
                                             @Nonnull
                                             io.vertx.core.MultiMap headers,
                                             @Nonnull
                                             KeepUser user)
                                      throws KeepExceptionServer

Throws:

KeepExceptionServer

Method Detail

getApiName

public java.lang.String getApiName()

Specified by:

getApiName in interface KeepSubscriberInfo

Returns:

the API Name of the database in use

getOperationId

public java.lang.String getOperationId()

Returns:

the operationId

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<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface io.reactivex.Emitter<T>

Specified by:

onComplete in interface io.reactivex.Observer<T>

onError

public void onError(java.lang.Throwable error)

Specified by:

onError in interface io.reactivex.Emitter<T>

Specified by:

onError in interface io.reactivex.Observer<T>

onNext

public void onNext(T data)

Specified by:

onNext in interface io.reactivex.Emitter<T>

Specified by:

onNext in interface io.reactivex.Observer<T>

onSubscribe

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

Specified by:

onSubscribe in interface io.reactivex.Observer<T>

serialize

public io.reactivex.ObservableEmitter<T> serialize()

Specified by:

serialize in interface io.reactivex.ObservableEmitter<T>

setAggregateResponses

public void setAggregateResponses(int aggregateResponses)

Description copied from interface: EventBusResponseSubscriber

Sets the batch count of responses to be bundled over the eventbus 0 = no bundling -1 = all (single response)

0 = the given number

Specified by:

setAggregateResponses in interface EventBusResponseSubscriber<T>

Parameters:

aggregateResponses -

• how many responses should be bundled 0 = none

setCacheHeader

public void setCacheHeader(java.lang.String cacheKey)

Parameters:

cacheKey -

setCancellable

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

Specified by:

setCancellable in interface io.reactivex.ObservableEmitter<T>

setDisposable

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

Specified by:

setDisposable in interface io.reactivex.ObservableEmitter<T>

tryOnError

public boolean tryOnError(java.lang.Throwable t)

Specified by:

tryOnError in interface io.reactivex.ObservableEmitter<T>

getSendCollector

protected abstract java.util.stream.Collector<T,?,?> getSendCollector()

Returns:

A Colletor that sends a combined value or null if empty