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.StreamOutput
drainHandler(Handler<Void> handler)
default Future<Void>
end()
Calls {code close()}.StreamOutput
exceptionHandler(Handler<Throwable> handler)
StreamOutput
setWriteQueueMaxSize(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:
exceptionHandler
in interfaceStreamBase
- Specified by:
exceptionHandler
in interfaceWriteStream<Buffer>
-
setWriteQueueMaxSize
StreamOutput setWriteQueueMaxSize(int i)
- Specified by:
setWriteQueueMaxSize
in interfaceWriteStream<Buffer>
-
drainHandler
StreamOutput drainHandler(Handler<Void> handler)
- Specified by:
drainHandler
in interfaceWriteStream<Buffer>
-
end
default Future<Void> end()
Calls {code close()}.- Specified by:
end
in interfaceWriteStream<Buffer>
-
-