com.hcl.domino.keep.eventbus

Class EventBusBufferResponseSubscriber

java.lang.Object

com.hcl.domino.keep.eventbus.AbstractEventBusResponseSubscriber<io.vertx.core.buffer.Buffer>

com.hcl.domino.keep.eventbus.EventBusBufferResponseSubscriber

All Implemented Interfaces:

EventBusResponseSubscriber<io.vertx.core.buffer.Buffer>, KeepSubscriberInfo, io.reactivex.Emitter<io.vertx.core.buffer.Buffer>, io.reactivex.ObservableEmitter<io.vertx.core.buffer.Buffer>, io.reactivex.Observer<io.vertx.core.buffer.Buffer>, java.io.Serializable

public class EventBusBufferResponseSubscriber
extends AbstractEventBusResponseSubscriber<io.vertx.core.buffer.Buffer>

Subscriber to wrap EventBus Buffer messages in an Observer/subscriber pattern

See Also:

Serialized Form

Field Summary

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

cancellable, logger

Constructor Summary

Constructors

Constructor and Description
EventBusBufferResponseSubscriber(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<EventBusBufferResponseSubscriber>	get(io.vertx.core.Vertx vertx, io.vertx.core.eventbus.Message<?> incoming, JwtManager jwtManager)
protected java.util.stream.Collector<io.vertx.core.buffer.Buffer,io.vertx.core.buffer.Buffer,io.vertx.core.buffer.Buffer>	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

EventBusBufferResponseSubscriber

public EventBusBufferResponseSubscriber(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<EventBusBufferResponseSubscriber> get(@Nonnull
                                                                         io.vertx.core.Vertx vertx,
                                                                         @Nonnull
                                                                         io.vertx.core.eventbus.Message<?> incoming,
                                                                         @Nonnull
                                                                         JwtManager jwtManager)

Parameters:

vertx -

• Runtime component

incoming -

• an incoming message

jwtManager -

• the JWT Manager

Returns:

a subscriber - subscriber to listen to

getSendCollector

protected java.util.stream.Collector<io.vertx.core.buffer.Buffer,io.vertx.core.buffer.Buffer,io.vertx.core.buffer.Buffer> getSendCollector()

Specified by:

getSendCollector in class AbstractEventBusResponseSubscriber<io.vertx.core.buffer.Buffer>

Returns:

A Colletor that sends a combined value or null if empty