| Package | Description |
|---|---|
| io.vertx.rxjava.rabbitmq |
| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<RabbitMQMessage> |
RabbitMQMessage.__TYPE_ARG |
| Modifier and Type | Method and Description |
|---|---|
static RabbitMQMessage |
RabbitMQMessage.newInstance(RabbitMQMessage arg) |
| Modifier and Type | Method and Description |
|---|---|
ReadStream<RabbitMQMessage> |
RabbitMQConsumer.fetch(long amount)
Fetch the specified
amount of elements. |
Pipe<RabbitMQMessage> |
RabbitMQConsumer.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Observable<RabbitMQMessage> |
RabbitMQConsumer.toObservable() |
| Modifier and Type | Method and Description |
|---|---|
RabbitMQConsumer |
RabbitMQConsumer.handler(Handler<RabbitMQMessage> messageArrived)
Set a message handler.
|
void |
RabbitMQConsumer.pipeTo(WriteStream<RabbitMQMessage> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
RabbitMQConsumer.pipeTo(WriteStream<RabbitMQMessage> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
Observable<Void> |
RabbitMQConsumer.pipeToObservable(WriteStream<RabbitMQMessage> dst)
|
Single<Void> |
RabbitMQConsumer.rxPipeTo(WriteStream<RabbitMQMessage> dst)
Pipe this
ReadStream to the WriteStream. |
Copyright © 2021 Eclipse. All rights reserved.