Modifier and Type | Method and Description |
---|---|
Pipe<AmqpMessage> |
AmqpReceiver.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<com.datastax.oss.driver.api.core.cql.Row> |
CassandraRowStream.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Long> |
TimeoutStream.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<DatagramPacket> |
DatagramSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Message<T>> |
MessageConsumer.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Buffer> |
AsyncFile.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Buffer> |
HttpClientResponse.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
ServerWebSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
WebSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
HttpServerFileUpload.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
HttpServerRequest.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<Buffer> |
WebSocketBase.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Buffer> |
NetSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Buffer> |
RecordParser.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Pipe<JsonEvent> |
JsonParser.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Pipe> |
Pipe.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
Pipe<T> |
Pipe.endOnComplete(boolean end)
Set to
true to call WriteStream.end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) when the source ReadStream completes, false otherwise. |
Pipe<T> |
Pipe.endOnFailure(boolean end)
Set to
true to call WriteStream.end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) when the source ReadStream fails, false otherwise. |
Pipe<T> |
Pipe.endOnSuccess(boolean end)
Set to
true to call WriteStream.end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) when the source ReadStream succeeds, false otherwise. |
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg) |
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Pipe<T> |
ReadStream.pipe()
Pause this stream and return a
Pipe to transfer the elements of this stream to a destination WriteStream . |
Modifier and Type | Method and Description |
---|---|
Pipe<JsonArray> |
SQLRowStream.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<TestCaseReport> |
TestSuiteReport.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Buffer> |
SockJSSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<KafkaConsumerRecord<K,V>> |
KafkaConsumer.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<String> |
PgChannel.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<RabbitMQMessage> |
RabbitMQConsumer.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<Response> |
RedisConnection.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Modifier and Type | Method and Description |
---|---|
Pipe<T> |
RowStream.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
Copyright © 2021 Eclipse. All rights reserved.