| Package | Description |
|---|---|
| io.vertx.core.streams | |
| io.vertx.reactivex.core.streams | |
| io.vertx.rxjava.core.streams | |
| io.vertx.rxjava3.core.streams |
| Modifier and Type | Method and Description |
|---|---|
Pipe<T> |
Pipe.endOnComplete(boolean end)
|
Pipe<T> |
Pipe.endOnFailure(boolean end)
|
Pipe<T> |
Pipe.endOnSuccess(boolean end)
|
default 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 |
Pipe.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg) |
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
| Constructor and Description |
|---|
Pipe(Pipe delegate) |
| Modifier and Type | Method and Description |
|---|---|
Pipe |
Pipe.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg) |
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
| Constructor and Description |
|---|
Pipe(Pipe delegate) |
| Modifier and Type | Method and Description |
|---|---|
Pipe |
Pipe.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg) |
static <T> Pipe<T> |
Pipe.newInstance(Pipe arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
| Constructor and Description |
|---|
Pipe(Pipe delegate) |
Copyright © 2021 Eclipse. All rights reserved.