Modifier and Type | Interface and Description |
---|---|
interface |
AmqpSender
AMQP Sender interface used to send messages.
|
Modifier and Type | Method and Description |
---|---|
default Future<Void> |
CassandraRowStream.pipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst) |
default void |
CassandraRowStream.pipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst,
Handler<AsyncResult<Void>> handler) |
Modifier and Type | Method and Description |
---|---|
WriteStream<Buffer> |
DatagramSocket.sender(int port,
String host)
|
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 |
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 | Method and Description |
---|---|
WriteStream<T> |
WriteStream.drainHandler(Handler<Void> handler)
Set a drain handler on the stream.
|
WriteStream<T> |
WriteStream.exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the write stream.
|
WriteStream<T> |
WriteStream.setWriteQueueMaxSize(int maxSize)
Set the maximum size of the write queue to
maxSize . |
Modifier and Type | Method and Description |
---|---|
default Future<Void> |
ReadStream.pipeTo(WriteStream<T> dst)
Same as
ReadStream.pipeTo(WriteStream, Handler) but returns a Future of the asynchronous result |
default void |
ReadStream.pipeTo(WriteStream<T> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream . |
static <T> Pump |
Pump.pump(ReadStream<T> rs,
WriteStream<T> ws)
Create a new
Pump with the given ReadStream and WriteStream |
static <T> Pump |
Pump.pump(ReadStream<T> rs,
WriteStream<T> ws,
int writeQueueMaxSize)
Create a new
Pump with the given ReadStream and WriteStream and
writeQueueMaxSize |
default Future<Void> |
Pipe.to(WriteStream<T> dst)
Same as
Pipe.to(WriteStream, Handler) but returns a Future of the asynchronous result |
void |
Pipe.to(WriteStream<T> dst,
Handler<AsyncResult<Void>> completionHandler)
Start to pipe the elements to the destination
WriteStream . |
Modifier and Type | Interface and Description |
---|---|
interface |
ReactiveWriteStream<T>
A Vert.x write stream that also implements reactive streams publisher interface.
|
Modifier and Type | Method and Description |
---|---|
static BodyCodec<Void> |
BodyCodec.pipe(WriteStream<Buffer> stream)
A body codec that pipes the body to a write stream.
|
static BodyCodec<Void> |
BodyCodec.pipe(WriteStream<Buffer> stream,
boolean close)
A body codec that pipes the body to a write stream.
|
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 | Interface and Description |
---|---|
interface |
GrpcClientRequest<Req,Resp>
A request to a gRPC server.
|
Modifier and Type | Interface and Description |
---|---|
interface |
GrpcWriteStream<T> |
Modifier and Type | Interface and Description |
---|---|
interface |
GrpcServerResponse<Req,Resp> |
Modifier and Type | Class and Description |
---|---|
class |
GrpcWriteStream<T> |
Modifier and Type | Method and Description |
---|---|
WriteStream<T> |
GrpcWriteStream.drainHandler(Handler<Void> hndlr) |
WriteStream<T> |
GrpcWriteStream.exceptionHandler(Handler<Throwable> hndlr) |
WriteStream<T> |
GrpcWriteStream.setWriteQueueMaxSize(int i) |
Modifier and Type | Method and Description |
---|---|
static <I,O> ReadStream<O> |
ClientCalls.manyToMany(io.vertx.core.impl.ContextInternal ctx,
Handler<WriteStream<I>> requestHandler,
java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate) |
static <I,O> io.grpc.stub.StreamObserver<I> |
ServerCalls.manyToMany(io.grpc.stub.StreamObserver<O> response,
String compression,
java.util.function.BiConsumer<ReadStream<I>,WriteStream<O>> delegate) |
static <I,O> Future<O> |
ClientCalls.manyToOne(io.vertx.core.impl.ContextInternal ctx,
Handler<WriteStream<I>> requestHandler,
java.util.function.Function<io.grpc.stub.StreamObserver<O>,io.grpc.stub.StreamObserver<I>> delegate) |
static <I,O> void |
ServerCalls.oneToMany(I request,
io.grpc.stub.StreamObserver<O> response,
String compression,
java.util.function.BiConsumer<I,WriteStream<O>> delegate) |
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 | Method and Description |
---|---|
static <T> WriteStreamObserver<T> |
RxHelper.toObserver(WriteStream<T> stream)
Adapts a Vert.x
WriteStream to an RxJava Observer . |
static <R,T> WriteStreamObserver<R> |
RxHelper.toObserver(WriteStream<T> stream,
java.util.function.Function<R,T> mapping)
Like
RxHelper.toObserver(WriteStream) , except the provided mapping function is applied to each Observable item. |
static <T> WriteStreamSubscriber<T> |
RxHelper.toSubscriber(WriteStream<T> stream)
Adapts a Vert.x
WriteStream to an RxJava Subscriber . |
static <R,T> WriteStreamSubscriber<R> |
RxHelper.toSubscriber(WriteStream<T> stream,
java.util.function.Function<R,T> mapping)
Like
RxHelper.toSubscriber(WriteStream) , except the provided mapping function is applied to each Flowable item. |
Modifier and Type | Method and Description |
---|---|
WriteStream |
WriteStream.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <T> WriteStream<T> |
WriteStream.newInstance(WriteStream arg) |
static <T> WriteStream<T> |
WriteStream.newInstance(WriteStream arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Modifier and Type | Method and Description |
---|---|
static <T> WriteStreamSubscriber<T> |
RxHelper.toSubscriber(WriteStream<T> stream)
Adapts a Vert.x
WriteStream to an RxJava Subscriber . |
static <R,T> WriteStreamSubscriber<R> |
RxHelper.toSubscriber(WriteStream<T> stream,
java.util.function.Function<R,T> mapping)
Like
RxHelper.toSubscriber(WriteStream) , except the provided mapping function is applied to each Observable item. |
Modifier and Type | Method and Description |
---|---|
WriteStream |
WriteStream.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <T> WriteStream<T> |
WriteStream.newInstance(WriteStream arg) |
static <T> WriteStream<T> |
WriteStream.newInstance(WriteStream arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Modifier and Type | Method and Description |
---|---|
static <T> WriteStreamObserver<T> |
RxHelper.toObserver(WriteStream<T> stream)
Adapts a Vert.x
WriteStream to an RxJava Observer . |
static <R,T> WriteStreamObserver<R> |
RxHelper.toObserver(WriteStream<T> stream,
java.util.function.Function<R,T> mapping)
Like
RxHelper.toObserver(WriteStream) , except the provided mapping function is applied to each Observable item. |
static <T> WriteStreamSubscriber<T> |
RxHelper.toSubscriber(WriteStream<T> stream)
Adapts a Vert.x
WriteStream to an RxJava Subscriber . |
static <R,T> WriteStreamSubscriber<R> |
RxHelper.toSubscriber(WriteStream<T> stream,
java.util.function.Function<R,T> mapping)
Like
RxHelper.toSubscriber(WriteStream) , except the provided mapping function is applied to each Flowable item. |
Modifier and Type | Method and Description |
---|---|
WriteStream |
WriteStream.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <T> WriteStream<T> |
WriteStream.newInstance(WriteStream arg) |
static <T> WriteStream<T> |
WriteStream.newInstance(WriteStream arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Copyright © 2024 Eclipse. All rights reserved.