Package | Description |
---|---|
io.vertx.core.spi | |
io.vertx.core.streams |
== Streams
There are several objects in Vert.x that allow items to be read from and written.
|
Modifier and Type | Method and Description |
---|---|
<T> Pump |
PumpFactory.pump(ReadStream<T> rs,
WriteStream<T> ws) |
<T> Pump |
PumpFactory.pump(ReadStream<T> rs,
WriteStream<T> ws,
int writeQueueMaxSize) |
Modifier and Type | Method and Description |
---|---|
static <T> Pump |
Pump.pump(ReadStream<T> rs,
WriteStream<T> ws)
Create a new
Pump with the given ReadStream and WriteStream |
static <T> Pump |
Pump.pump(ReadStream<T> rs,
WriteStream<T> ws,
int writeQueueMaxSize)
Create a new
Pump with the given ReadStream and WriteStream and
writeQueueMaxSize |
Pump |
Pump.setWriteQueueMaxSize(int maxSize)
Set the write queue max size to
maxSize |
Pump |
Pump.start()
Start the Pump.
|
Pump |
Pump.stop()
Stop the Pump.
|
Copyright © 2017. All rights reserved.