com.hcl.domino.keep.eventbus

Interface EventBusResponseSubscriber<T>

Type Parameters:

T - The datatype being sent over the EventBus

All Superinterfaces:

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

All Known Implementing Classes:

AbstractEventBusResponseSubscriber, EventBusBufferResponseSubscriber, EventBusJsonResponseSubscriber

public interface EventBusResponseSubscriber<T>
extends io.reactivex.ObservableEmitter<T>, io.reactivex.Observer<T>, java.io.Serializable, KeepSubscriberInfo

Interface describing all methods an EvenBusResponseSubscriber needs and extends: - ObservableEmitter - Serializable - KeepSubscriberInfo

Method Summary

Modifier and Type	Method and Description
void	setAggregateResponses(int aggregateResponses) Sets the batch count of responses to be bundled over the eventbus 0 = no bundling -1 = all (single response)

Methods inherited from interface io.reactivex.ObservableEmitter

isDisposed, serialize, setCancellable, setDisposable, tryOnError

Methods inherited from interface io.reactivex.Emitter

onComplete, onError, onNext

Methods inherited from interface io.reactivex.Observer

onComplete, onError, onNext, onSubscribe

Methods inherited from interface com.hcl.domino.keep.eventbus.KeepSubscriberInfo

getApiName, getUser

Method Detail

setAggregateResponses

void setAggregateResponses(int aggregateResponses)

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

0 = the given number

Parameters:

aggregateResponses -

• how many responses should be bundled 0 = none