com.hcl.domino.keep.eventbus

Class EventBusJsonResponseSubscriber

java.lang.Object

com.hcl.domino.keep.eventbus.AbstractEventBusResponseSubscriber<io.vertx.core.json.JsonObject>

com.hcl.domino.keep.eventbus.EventBusJsonResponseSubscriber

All Implemented Interfaces:

EventBusResponseSubscriber<io.vertx.core.json.JsonObject>, KeepSubscriberInfo, io.reactivex.Emitter<io.vertx.core.json.JsonObject>, io.reactivex.ObservableEmitter<io.vertx.core.json.JsonObject>, io.reactivex.Observer<io.vertx.core.json.JsonObject>, java.io.Serializable

public class EventBusJsonResponseSubscriber
extends AbstractEventBusResponseSubscriber<io.vertx.core.json.JsonObject>

See Also:

Serialized Form

Field Summary

Fields inherited from class com.hcl.domino.keep.eventbus.AbstractEventBusResponseSubscriber

cancellable, logger

Constructor Summary

Constructors

Constructor and Description
EventBusJsonResponseSubscriber(io.vertx.core.Vertx vertx, io.vertx.core.MultiMap headers, KeepUser user)

Method Summary

Modifier and Type	Method and Description
static io.vertx.core.Future<EventBusJsonResponseSubscriber>	get(io.vertx.core.Vertx vertx, io.vertx.core.eventbus.Message<?> incoming, JwtManager jwtManager)
protected java.util.stream.Collector<io.vertx.core.json.JsonObject,io.vertx.core.json.JsonArray,io.vertx.core.json.JsonArray>	getSendCollector()

Methods inherited from class com.hcl.domino.keep.eventbus.AbstractEventBusResponseSubscriber

getApiName, getOperationId, getUser, isDisposed, onComplete, onError, onNext, onSubscribe, serialize, setAggregateResponses, setCacheHeader, setCancellable, setDisposable, tryOnError

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusJsonResponseSubscriber

public EventBusJsonResponseSubscriber(io.vertx.core.Vertx vertx,
                                      io.vertx.core.MultiMap headers,
                                      KeepUser user)
                               throws KeepExceptionServer

Parameters:

vertx -

headers -

user -

Throws:

KeepExceptionServer

Method Detail

get

public static io.vertx.core.Future<EventBusJsonResponseSubscriber> get(@Nonnull
                                                                       io.vertx.core.Vertx vertx,
                                                                       @Nonnull
                                                                       io.vertx.core.eventbus.Message<?> incoming,
                                                                       @Nonnull
                                                                       JwtManager jwtManager)

Parameters:

vertx -

• Runtime

incoming -

• incoming message for the bus

jwtManager -

• the JWT manager

Returns:

a subscriber - Subscriber listening to the bus

getSendCollector

protected java.util.stream.Collector<io.vertx.core.json.JsonObject,io.vertx.core.json.JsonArray,io.vertx.core.json.JsonArray> getSendCollector()

Specified by:

getSendCollector in class AbstractEventBusResponseSubscriber<io.vertx.core.json.JsonObject>

Returns:

A Colletor that sends a combined value or null if empty