Modifier and Type | Interface and Description |
---|---|
interface |
AmqpReceiver
Interface used to consume AMQP message as a stream of message.
|
interface |
AmqpSender
AMQP Sender interface used to send messages.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CassandraRowStream
A
ReadStream for Row consumption. |
Modifier and Type | Interface and Description |
---|---|
interface |
TimeoutStream
A timeout stream is triggered by a timer, the
Handler will be call when the timer is fired,
it can be once or several times depending on the nature of the timer related to this stream. |
Modifier and Type | Interface and Description |
---|---|
interface |
DatagramSocket
A datagram socket can be used to send
DatagramPacket 's to remote datagram servers
and receive DatagramPacket s . |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageConsumer<T>
An event bus consumer object representing a stream of message to an
EventBus address that can
be read from. |
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncFile
Represents a file on the file-system which can be read from, or written to asynchronously.
|
Modifier and Type | Interface and Description |
---|---|
interface |
HttpClientRequest
Represents a client-side HTTP request.
|
interface |
HttpClientResponse
Represents a client-side HTTP response.
|
interface |
HttpServerFileUpload
Represents an file upload from an HTML FORM.
|
interface |
HttpServerRequest
Represents a server-side HTTP request.
|
interface |
HttpServerResponse
Represents a server-side HTTP response.
|
interface |
ServerWebSocket
Represents a server side WebSocket.
|
interface |
WebSocket
Represents a client-side WebSocket.
|
interface |
WebSocketBase
Base WebSocket implementation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
NetSocket
Represents a socket-like interface to a TCP connection on either the
client or the server side.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JsonParser
A parser class which allows to incrementally parse json elements and emit json parse events instead of parsing a json
element fully.
|
interface |
RecordParser
A helper class which allows you to easily parse protocols which are delimited by a sequence of bytes, or fixed
size records.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ReadStream<T>
Represents a stream of items that can be read from.
|
interface |
WriteStream<T>
Represents a stream of data that can be written to.
|
Modifier and Type | Method and Description |
---|---|
StreamBase |
StreamBase.exceptionHandler(Handler<Throwable> handler)
Set an exception handler.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ReactiveReadStream<T>
A Vert.x read stream that also implements reactive streams subscriber interface.
|
interface |
ReactiveWriteStream<T>
A Vert.x write stream that also implements reactive streams publisher interface.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SQLRowStream
A ReadStream of Rows from the underlying RDBMS.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TestSuiteReport
The test suite reports is basically a stream of events reporting the test suite execution.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BodyStream<T>
The body stream decodes a
WriteStream into the a T instance. |
Modifier and Type | Interface and Description |
---|---|
interface |
SockJSSocket
You interact with SockJS clients through instances of SockJS socket.
|
Modifier and Type | Class and Description |
---|---|
class |
GrpcWriteStream<T> |
Modifier and Type | Interface and Description |
---|---|
interface |
KafkaConsumer<K,V>
Vert.x Kafka consumer.
|
interface |
KafkaReadStream<K,V>
A
ReadStream for consuming Kafka ConsumerRecord . |
Modifier and Type | Interface and Description |
---|---|
interface |
KafkaProducer<K,V>
Vert.x Kafka producer.
|
interface |
KafkaWriteStream<K,V>
A
WriteStream for writing to Kafka ProducerRecord . |
Modifier and Type | Interface and Description |
---|---|
interface |
PgChannel
A channel to Postgres that tracks the subscription to a given Postgres channel using the
LISTEN/UNLISTEN commands. |
Modifier and Type | Interface and Description |
---|---|
interface |
RabbitMQConsumer
A stream of messages from a rabbitmq queue.
|
Modifier and Type | Method and Description |
---|---|
StreamBase |
StreamBase.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static StreamBase |
StreamBase.newInstance(StreamBase arg) |
Modifier and Type | Interface and Description |
---|---|
interface |
RedisConnection
A simple Redis client.
|
Modifier and Type | Class and Description |
---|---|
class |
ReadStreamSubscriber<R,J>
|
Modifier and Type | Method and Description |
---|---|
StreamBase |
StreamBase.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static StreamBase |
StreamBase.newInstance(StreamBase arg) |
Modifier and Type | Interface and Description |
---|---|
interface |
RowStream<T>
A row oriented stream.
|
Copyright © 2021 Eclipse. All rights reserved.