Uses of Interface
io.vertx.rxjava3.core.streams.StreamBase

Packages that use StreamBase

Package	Description
io.vertx.rxjava3.amqp
io.vertx.rxjava3.cassandra
io.vertx.rxjava3.core.eventbus
io.vertx.rxjava3.core.file
io.vertx.rxjava3.core.http
io.vertx.rxjava3.core.net
io.vertx.rxjava3.core.parsetools
io.vertx.rxjava3.core.streams
io.vertx.rxjava3.ext.unit.report
io.vertx.rxjava3.ext.web.handler.sockjs
io.vertx.rxjava3.grpc.client
io.vertx.rxjava3.grpc.common
io.vertx.rxjava3.grpc.server
io.vertx.rxjava3.kafka.client.consumer
io.vertx.rxjava3.kafka.client.producer
io.vertx.rxjava3.pgclient.pubsub
io.vertx.rxjava3.rabbitmq
io.vertx.rxjava3.redis.client
io.vertx.rxjava3.sqlclient

Uses of StreamBase in io.vertx.rxjava3.amqp

Classes in io.vertx.rxjava3.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.rxjava3.cassandra

Classes in io.vertx.rxjava3.cassandra that implement StreamBase

Modifier and Type	Class	Description
class	CassandraRowStream	A for consumption.

Uses of StreamBase in io.vertx.rxjava3.core.eventbus

Classes in io.vertx.rxjava3.core.eventbus that implement StreamBase

Modifier and Type	Class	Description
class	MessageConsumer<T>	An event bus consumer object representing a stream of message to an EventBus address that can be read from.

Uses of StreamBase in io.vertx.rxjava3.core.file

Classes in io.vertx.rxjava3.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.rxjava3.core.http

Subinterfaces of StreamBase in io.vertx.rxjava3.core.http

Modifier and Type	Interface	Description
interface	WebSocketBase	Base WebSocket implementation.

Classes in io.vertx.rxjava3.core.http that implement StreamBase

Modifier and Type	Class	Description
class	ClientWebSocket	Represents a client-side WebSocket.
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	Common WebSocket implementation.

Uses of StreamBase in io.vertx.rxjava3.core.net

Classes in io.vertx.rxjava3.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.rxjava3.core.parsetools

Classes in io.vertx.rxjava3.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.rxjava3.core.streams

Subinterfaces of StreamBase in io.vertx.rxjava3.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.rxjava3.core.streams that return StreamBase

Modifier and Type	Method	Description
StreamBase	StreamBase.exceptionHandler(Handler<Throwable> handler)	Set an exception handler.
static StreamBase	StreamBase.newInstance(StreamBase arg)

Uses of StreamBase in io.vertx.rxjava3.ext.unit.report

Classes in io.vertx.rxjava3.ext.unit.report that implement StreamBase

Modifier and Type	Class	Description
class	TestSuiteReport	The test suite reports is basically a stream of events reporting the test suite execution.

Uses of StreamBase in io.vertx.rxjava3.ext.web.handler.sockjs

Classes in io.vertx.rxjava3.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.rxjava3.grpc.client

Classes in io.vertx.rxjava3.grpc.client that implement StreamBase

Modifier and Type	Class	Description
class	GrpcClientRequest<Req,Resp>	A request to a gRPC server.
class	GrpcClientResponse<Req,Resp>	A response from a gRPC server.

Uses of StreamBase in io.vertx.rxjava3.grpc.common

Classes in io.vertx.rxjava3.grpc.common that implement StreamBase

Modifier and Type	Class	Description
class	GrpcReadStream<T>
class	GrpcWriteStream<T>

Uses of StreamBase in io.vertx.rxjava3.grpc.server

Classes in io.vertx.rxjava3.grpc.server that implement StreamBase

Modifier and Type	Class	Description
class	GrpcServerRequest<Req,Resp>
class	GrpcServerResponse<Req,Resp>

Uses of StreamBase in io.vertx.rxjava3.kafka.client.consumer

Classes in io.vertx.rxjava3.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.rxjava3.kafka.client.producer

Classes in io.vertx.rxjava3.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.rxjava3.pgclient.pubsub

Classes in io.vertx.rxjava3.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 the LISTEN/UNLISTEN commands.

Uses of StreamBase in io.vertx.rxjava3.rabbitmq

Classes in io.vertx.rxjava3.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.rxjava3.redis.client

Classes in io.vertx.rxjava3.redis.client that implement StreamBase

Modifier and Type	Class	Description
class	RedisConnection	A simple Redis client.

Uses of StreamBase in io.vertx.rxjava3.sqlclient

Classes in io.vertx.rxjava3.sqlclient that implement StreamBase

Modifier and Type	Class	Description
class	RowStream<T>	A row oriented stream.