Package io.reactiverse.childprocess
Interface StreamInput
-
- All Superinterfaces:
StreamBase
public interface StreamInput extends StreamBase
The input of a process: a stream ofbuffers
.- Author:
- Julien Viet
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamInput
endHandler(Handler<Void> handler)
Set an end handler.StreamInput
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.StreamInput
handler(Handler<Buffer> handler)
Set a buffer handler.
-
-
-
Method Detail
-
exceptionHandler
StreamInput exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.- Specified by:
exceptionHandler
in interfaceStreamBase
- Parameters:
handler
- the exception handler- Returns:
- a reference to this, so the API can be used fluently
-
handler
StreamInput handler(Handler<Buffer> handler)
Set a buffer handler. As bytes are read, the handler will be called with the data.- Returns:
- a reference to this, so the API can be used fluently
-
endHandler
StreamInput endHandler(Handler<Void> handler)
Set an end handler. Once the stream has ended, and there is no more data to be read, this handler will be called.- Returns:
- a reference to this, so the API can be used fluently
-
-