Package io.reactiverse.childprocess
Interface StreamOutput
-
- All Superinterfaces:
StreamBase,WriteStream<Buffer>
public interface StreamOutput extends WriteStream<Buffer>
The output of a process: a stream ofbuffers.- Author:
- Julien Viet
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description Future<Void>close()Close the stream.StreamOutputdrainHandler(Handler<Void> handler)default Future<Void>end()Calls {code close()}.StreamOutputexceptionHandler(Handler<Throwable> handler)StreamOutputsetWriteQueueMaxSize(int i)Future<Void>write(Buffer buffer)-
Methods inherited from interface io.vertx.core.streams.WriteStream
end, writeQueueFull
-
-
-
-
Method Detail
-
exceptionHandler
StreamOutput exceptionHandler(Handler<Throwable> handler)
- Specified by:
exceptionHandlerin interfaceStreamBase- Specified by:
exceptionHandlerin interfaceWriteStream<Buffer>
-
setWriteQueueMaxSize
StreamOutput setWriteQueueMaxSize(int i)
- Specified by:
setWriteQueueMaxSizein interfaceWriteStream<Buffer>
-
drainHandler
StreamOutput drainHandler(Handler<Void> handler)
- Specified by:
drainHandlerin interfaceWriteStream<Buffer>
-
end
default Future<Void> end()
Calls {code close()}.- Specified by:
endin interfaceWriteStream<Buffer>
-
-