Uses of Interface
io.vertx.reactivex.core.streams.WriteStream
-
-
Uses of WriteStream in io.vertx.reactivex.amqp
Classes in io.vertx.reactivex.amqp that implement WriteStream Modifier and Type Class Description classAmqpSenderAMQP Sender interface used to send messages.Methods in io.vertx.reactivex.amqp that return WriteStream Modifier and Type Method Description WriteStream<AmqpMessage>AmqpSender. drainHandler(Handler<Void> handler)Set a drain handler on the stream.Methods in io.vertx.reactivex.amqp with parameters of type WriteStream Modifier and Type Method Description Future<Void>AmqpReceiver. pipeTo(WriteStream<AmqpMessage> dst)Pipe thisReadStreamto theWriteStream.CompletableAmqpReceiver. rxPipeTo(WriteStream<AmqpMessage> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.cassandra
Methods in io.vertx.reactivex.cassandra with parameters of type WriteStream Modifier and Type Method Description Future<Void>CassandraRowStream. pipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)CompletableCassandraRowStream. rxPipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst) -
Uses of WriteStream in io.vertx.reactivex.core.datagram
Methods in io.vertx.reactivex.core.datagram that return WriteStream Modifier and Type Method Description WriteStream<Buffer>DatagramSocket. sender(int port, String host)Returns aWriteStreamable to send to theSocketAddress. -
Uses of WriteStream in io.vertx.reactivex.core.eventbus
Methods in io.vertx.reactivex.core.eventbus with parameters of type WriteStream Modifier and Type Method Description Future<Void>MessageConsumer. pipeTo(WriteStream<Message<T>> dst)Pipe thisReadStreamto theWriteStream.CompletableMessageConsumer. rxPipeTo(WriteStream<Message<T>> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.core.file
Classes in io.vertx.reactivex.core.file that implement WriteStream Modifier and Type Class Description classAsyncFileRepresents a file on the file-system which can be read from, or written to asynchronously.Methods in io.vertx.reactivex.core.file with parameters of type WriteStream Modifier and Type Method Description Future<Void>AsyncFile. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableAsyncFile. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.core.http
Subinterfaces of WriteStream in io.vertx.reactivex.core.http Modifier and Type Interface Description interfaceWebSocketBaseBase WebSocket implementation.Classes in io.vertx.reactivex.core.http that implement WriteStream Modifier and Type Class Description classClientWebSocketRepresents a client-side WebSocket.classHttpClientRequestRepresents a client-side HTTP request.classHttpServerResponseRepresents a server-side HTTP response.classServerWebSocketRepresents a server side WebSocket.classWebSocketCommon WebSocket implementation.Methods in io.vertx.reactivex.core.http with parameters of type WriteStream Modifier and Type Method Description Future<Void>ClientWebSocket. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.Future<Void>HttpClientResponse. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.Future<Void>HttpServerFileUpload. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.Future<Void>HttpServerRequest. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.Future<Void>ServerWebSocket. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.Future<Void>WebSocket. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.Future<Void>WebSocketBase. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableClientWebSocket. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableHttpClientResponse. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableHttpServerFileUpload. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableHttpServerRequest. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableServerWebSocket. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableWebSocket. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableWebSocketBase. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.core.net
Classes in io.vertx.reactivex.core.net that implement WriteStream Modifier and Type Class Description classNetSocketRepresents a socket-like interface to a TCP connection on either the client or the server side.Methods in io.vertx.reactivex.core.net with parameters of type WriteStream Modifier and Type Method Description Future<Void>NetSocket. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableNetSocket. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.core.parsetools
Methods in io.vertx.reactivex.core.parsetools with parameters of type WriteStream Modifier and Type Method Description Future<Void>JsonParser. pipeTo(WriteStream<JsonEvent> dst)Pipe thisReadStreamto theWriteStream.Future<Void>RecordParser. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableJsonParser. rxPipeTo(WriteStream<JsonEvent> dst)Pipe thisReadStreamto theWriteStream.CompletableRecordParser. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.core.streams
Methods in io.vertx.reactivex.core.streams that return WriteStream Modifier and Type Method 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.static <T> WriteStream<T>WriteStream. newInstance(WriteStream arg)static <T> WriteStream<T>WriteStream. newInstance(WriteStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)WriteStream<T>WriteStream. setWriteQueueMaxSize(int maxSize)Set the maximum size of the write queue tomaxSize.Methods in io.vertx.reactivex.core.streams with parameters of type WriteStream Modifier and Type Method Description Future<Void>ReadStream. pipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream.CompletableReadStream. rxPipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream.CompletablePipe. rxTo(WriteStream<T> dst)Start to pipe the elements to the destinationWriteStream.Future<Void>Pipe. to(WriteStream<T> dst)Start to pipe the elements to the destinationWriteStream. -
Uses of WriteStream in io.vertx.reactivex.ext.mongo
Methods in io.vertx.reactivex.ext.mongo with parameters of type WriteStream Modifier and Type Method Description Future<Long>MongoGridFsClient. downloadByFileName(WriteStream<Buffer> stream, String fileName)Future<Long>MongoGridFsClient. downloadByFileNameWithOptions(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options)Future<Long>MongoGridFsClient. downloadById(WriteStream<Buffer> stream, String id)Single<Long>MongoGridFsClient. rxDownloadByFileName(WriteStream<Buffer> stream, String fileName)Single<Long>MongoGridFsClient. rxDownloadByFileNameWithOptions(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options)Single<Long>MongoGridFsClient. rxDownloadById(WriteStream<Buffer> stream, String id) -
Uses of WriteStream in io.vertx.reactivex.ext.unit.report
Methods in io.vertx.reactivex.ext.unit.report with parameters of type WriteStream Modifier and Type Method Description Future<Void>TestSuiteReport. pipeTo(WriteStream<TestCaseReport> dst)Pipe thisReadStreamto theWriteStream.CompletableTestSuiteReport. rxPipeTo(WriteStream<TestCaseReport> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.ext.web.codec
Methods in io.vertx.reactivex.ext.web.codec with parameters of type WriteStream Modifier and Type Method 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. -
Uses of WriteStream in io.vertx.reactivex.ext.web.handler.sockjs
Classes in io.vertx.reactivex.ext.web.handler.sockjs that implement WriteStream Modifier and Type Class Description classSockJSSocketYou interact with SockJS clients through instances of SockJS socket.Methods in io.vertx.reactivex.ext.web.handler.sockjs with parameters of type WriteStream Modifier and Type Method Description Future<Void>SockJSSocket. pipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream.CompletableSockJSSocket. rxPipeTo(WriteStream<Buffer> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.grpc.client
Classes in io.vertx.reactivex.grpc.client that implement WriteStream Modifier and Type Class Description classGrpcClientRequest<Req,Resp>A request to a gRPC server.Methods in io.vertx.reactivex.grpc.client with parameters of type WriteStream Modifier and Type Method Description Future<Void>GrpcClientResponse. pipeTo(WriteStream<Resp> dst)Pipe thisReadStreamto theWriteStream.CompletableGrpcClientResponse. rxPipeTo(WriteStream<Resp> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.grpc.common
Classes in io.vertx.reactivex.grpc.common that implement WriteStream Modifier and Type Class Description classGrpcWriteStream<T>Methods in io.vertx.reactivex.grpc.common with parameters of type WriteStream Modifier and Type Method Description Future<Void>GrpcReadStream. pipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream.CompletableGrpcReadStream. rxPipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.grpc.server
Classes in io.vertx.reactivex.grpc.server that implement WriteStream Modifier and Type Class Description classGrpcServerResponse<Req,Resp>Methods in io.vertx.reactivex.grpc.server with parameters of type WriteStream Modifier and Type Method Description Future<Void>GrpcServerRequest. pipeTo(WriteStream<Req> dst)Pipe thisReadStreamto theWriteStream.CompletableGrpcServerRequest. rxPipeTo(WriteStream<Req> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.kafka.client.consumer
Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type WriteStream Modifier and Type Method Description Future<Void>KafkaConsumer. pipeTo(WriteStream<KafkaConsumerRecord<K,V>> dst)Pipe thisReadStreamto theWriteStream.CompletableKafkaConsumer. rxPipeTo(WriteStream<KafkaConsumerRecord<K,V>> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.kafka.client.producer
Classes in io.vertx.reactivex.kafka.client.producer that implement WriteStream Modifier and Type Class Description classKafkaProducer<K,V>Vert.x Kafka producer. -
Uses of WriteStream in io.vertx.reactivex.pgclient.pubsub
Methods in io.vertx.reactivex.pgclient.pubsub with parameters of type WriteStream Modifier and Type Method Description Future<Void>PgChannel. pipeTo(WriteStream<String> dst)Pipe thisReadStreamto theWriteStream.CompletablePgChannel. rxPipeTo(WriteStream<String> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.rabbitmq
Methods in io.vertx.reactivex.rabbitmq with parameters of type WriteStream Modifier and Type Method Description Future<Void>RabbitMQConsumer. pipeTo(WriteStream<RabbitMQMessage> dst)Pipe thisReadStreamto theWriteStream.CompletableRabbitMQConsumer. rxPipeTo(WriteStream<RabbitMQMessage> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.redis.client
Methods in io.vertx.reactivex.redis.client with parameters of type WriteStream Modifier and Type Method Description Future<Void>RedisConnection. pipeTo(WriteStream<Response> dst)Pipe thisReadStreamto theWriteStream.CompletableRedisConnection. rxPipeTo(WriteStream<Response> dst)Pipe thisReadStreamto theWriteStream. -
Uses of WriteStream in io.vertx.reactivex.sqlclient
Methods in io.vertx.reactivex.sqlclient with parameters of type WriteStream Modifier and Type Method Description Future<Void>RowStream. pipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream.CompletableRowStream. rxPipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream.
-