| Constructor and Description |
|---|
PipeImpl(ReadStream<T> src) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the pipe.
|
Pipe<T> |
endOnComplete(boolean end)
|
Pipe<T> |
endOnFailure(boolean end)
|
Pipe<T> |
endOnSuccess(boolean end)
|
void |
to(WriteStream<T> ws)
Like
Pipe.to(WriteStream, Handler) but without a completion handler |
void |
to(WriteStream<T> ws,
Handler<AsyncResult<Void>> completionHandler)
Start to pipe the elements to the destination
WriteStream. |
public PipeImpl(ReadStream<T> src)
public Pipe<T> endOnFailure(boolean end)
PipeendOnFailure in interface Pipe<T>end - true to end the stream on a source ReadStream failurepublic Pipe<T> endOnSuccess(boolean end)
PipeendOnSuccess in interface Pipe<T>end - true to end the stream on a source ReadStream successpublic Pipe<T> endOnComplete(boolean end)
Pipetrue to call WriteStream.end() when the source ReadStream completes, false otherwise.
Calling this overwrites Pipe.endOnFailure(boolean) and Pipe.endOnSuccess(boolean).
endOnComplete in interface Pipe<T>end - true to end the stream on a source ReadStream completionpublic void to(WriteStream<T> ws)
PipePipe.to(WriteStream, Handler) but without a completion handlerpublic void to(WriteStream<T> ws, Handler<AsyncResult<Void>> completionHandler)
PipeWriteStream.
When the operation fails with a write error, the source stream is resumed.
Copyright © 2020. All rights reserved.