public class EventBusJsonResponseSubscriber extends AbstractEventBusResponseSubscriber<io.vertx.core.json.JsonObject>
cancellable, logger
Constructor and Description |
---|
EventBusJsonResponseSubscriber(io.vertx.core.Vertx vertx,
io.vertx.core.MultiMap headers,
KeepUser user) |
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() |
getApiName, getOperationId, getUser, isDisposed, onComplete, onError, onNext, onSubscribe, serialize, setAggregateResponses, setCacheHeader, setCancellable, setDisposable, tryOnError
public EventBusJsonResponseSubscriber(io.vertx.core.Vertx vertx, io.vertx.core.MultiMap headers, KeepUser user) throws KeepExceptionServer
vertx
- headers
- user
- KeepExceptionServer
public static io.vertx.core.Future<EventBusJsonResponseSubscriber> get(@Nonnull io.vertx.core.Vertx vertx, @Nonnull io.vertx.core.eventbus.Message<?> incoming, @Nonnull JwtManager jwtManager)
vertx
- incoming
- jwtManager
- protected java.util.stream.Collector<io.vertx.core.json.JsonObject,io.vertx.core.json.JsonArray,io.vertx.core.json.JsonArray> getSendCollector()
getSendCollector
in class AbstractEventBusResponseSubscriber<io.vertx.core.json.JsonObject>