Uses of Interface
io.vertx.mutiny.core.streams.StreamBase
-
-
Uses of StreamBase in io.vertx.mutiny.amqp
Classes in io.vertx.mutiny.amqp that implement StreamBase Modifier and Type Class Description class
AmqpReceiver
Interface used to consume AMQP message as a stream of message.class
AmqpSender
AMQP Sender interface used to send messages. -
Uses of StreamBase in io.vertx.mutiny.cassandra
Classes in io.vertx.mutiny.cassandra that implement StreamBase Modifier and Type Class Description class
CassandraRowStream
A for consumption. -
Uses of StreamBase in io.vertx.mutiny.core
Classes in io.vertx.mutiny.core that implement StreamBase Modifier and Type Class Description class
TimeoutStream
A timeout stream is triggered by a timer, theHandler
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. -
Uses of StreamBase in io.vertx.mutiny.core.datagram
Classes in io.vertx.mutiny.core.datagram that implement StreamBase Modifier and Type Class Description class
DatagramSocket
A datagram socket can be used to sendDatagramPacket
's to remote datagram servers and receiveDatagramPacket
s . -
Uses of StreamBase in io.vertx.mutiny.core.eventbus
Classes in io.vertx.mutiny.core.eventbus that implement StreamBase Modifier and Type Class Description class
MessageConsumer<T>
An event bus consumer object representing a stream of message to anEventBus
address that can be read from. -
Uses of StreamBase in io.vertx.mutiny.core.file
Classes in io.vertx.mutiny.core.file that implement StreamBase Modifier and Type Class Description class
AsyncFile
Represents a file on the file-system which can be read from, or written to asynchronously. -
Uses of StreamBase in io.vertx.mutiny.core.http
Subinterfaces of StreamBase in io.vertx.mutiny.core.http Modifier and Type Interface Description interface
WebSocketBase
Base WebSocket implementation.Classes in io.vertx.mutiny.core.http that implement StreamBase Modifier and Type Class Description class
ClientWebSocket
Represents a client-side WebSocket initially not connected.class
HttpClientRequest
Represents a client-side HTTP request.class
HttpClientResponse
Represents a client-side HTTP response.class
HttpServerFileUpload
Represents an file upload from an HTML FORM.class
HttpServerRequest
Represents a server-side HTTP request.class
HttpServerResponse
Represents a server-side HTTP response.class
ServerWebSocket
Represents a server side WebSocket.class
WebSocket
Represents a client-side WebSocket. -
Uses of StreamBase in io.vertx.mutiny.core.net
Classes in io.vertx.mutiny.core.net that implement StreamBase Modifier and Type Class Description class
NetSocket
Represents a socket-like interface to a TCP connection on either the client or the server side. -
Uses of StreamBase in io.vertx.mutiny.core.parsetools
Classes in io.vertx.mutiny.core.parsetools that implement StreamBase Modifier and Type Class Description class
JsonParser
A parser class which allows to incrementally parse json elements and emit json parse events instead of parsing a json element fully.class
RecordParser
A helper class which allows you to easily parse protocols which are delimited by a sequence of bytes, or fixed size records. -
Uses of StreamBase in io.vertx.mutiny.core.streams
Subinterfaces of StreamBase in io.vertx.mutiny.core.streams Modifier and Type Interface 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.Methods in io.vertx.mutiny.core.streams that return StreamBase Modifier and Type Method Description StreamBase
StreamBase. exceptionHandler(Consumer<Throwable> handler)
static StreamBase
StreamBase. newInstance(io.vertx.core.streams.StreamBase arg)
-
Uses of StreamBase in io.vertx.mutiny.ext.sql
Classes in io.vertx.mutiny.ext.sql that implement StreamBase Modifier and Type Class Description class
SQLRowStream
A ReadStream of Rows from the underlying RDBMS. -
Uses of StreamBase in io.vertx.mutiny.ext.web.handler.sockjs
Classes in io.vertx.mutiny.ext.web.handler.sockjs that implement StreamBase Modifier and Type Class Description class
SockJSSocket
You interact with SockJS clients through instances of SockJS socket. -
Uses of StreamBase in io.vertx.mutiny.kafka.client.consumer
Classes in io.vertx.mutiny.kafka.client.consumer that implement StreamBase Modifier and Type Class Description class
KafkaConsumer<K,V>
Vert.x Kafka consumer. -
Uses of StreamBase in io.vertx.mutiny.kafka.client.producer
Classes in io.vertx.mutiny.kafka.client.producer that implement StreamBase Modifier and Type Class Description class
KafkaProducer<K,V>
Vert.x Kafka producer. -
Uses of StreamBase in io.vertx.mutiny.pgclient.pubsub
Classes in io.vertx.mutiny.pgclient.pubsub that implement StreamBase Modifier and Type Class Description class
PgChannel
A channel to Postgres that tracks the subscription to a given Postgres channel using theLISTEN/UNLISTEN
commands. -
Uses of StreamBase in io.vertx.mutiny.rabbitmq
Classes in io.vertx.mutiny.rabbitmq that implement StreamBase Modifier and Type Class Description class
RabbitMQConsumer
A stream of messages from a rabbitmq queue. -
Uses of StreamBase in io.vertx.mutiny.redis.client
Classes in io.vertx.mutiny.redis.client that implement StreamBase Modifier and Type Class Description class
RedisConnection
A simple Redis client. -
Uses of StreamBase in io.vertx.mutiny.sqlclient
Classes in io.vertx.mutiny.sqlclient that implement StreamBase Modifier and Type Class Description class
RowStream<T>
A row oriented stream.
-