Constructor and Description |
---|
ReadStreamAdapter(ReadStream<R> stream,
java.util.function.Function<J,R> adapter) |
Modifier and Type | Class and Description |
---|---|
class |
TimeoutStream
A timeout stream is triggered by a timer, the
io.vertx.rxjava.core.Handler will be call when the timer is fired,
it can be once or several times depending on the nature of the timer related to this stream. |
Modifier and Type | Class and Description |
---|---|
class |
DatagramSocket
A datagram socket can be used to send
DatagramPacket 's to remote datagram servers
and receive DatagramPacket s . |
Modifier and Type | Class and Description |
---|---|
class |
MessageConsumer<T>
An event bus consumer object representing a stream of message to an
EventBus address that can
be read from. |
Modifier and Type | Method and Description |
---|---|
ReadStream<T> |
MessageConsumer.bodyStream() |
Modifier and Type | Class and Description |
---|---|
class |
AsyncFile
Represents a file on the file-system which can be read from, or written to asynchronously.
|
Modifier and Type | Interface and Description |
---|---|
interface |
WebSocketBase
Base WebSocket implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
HttpClientRequest
Represents a client-side HTTP request.
|
class |
HttpClientResponse
Represents a client-side HTTP response.
|
class |
HttpServerFileUpload
Represents an file upload from an HTML FORM.
|
class |
HttpServerRequest
Represents a server-side HTTP request.
|
class |
HttpServerRequestStream
|
class |
ServerWebSocket
Represents a server side WebSocket.
|
class |
ServerWebSocketStream
|
class |
WebSocket
Represents a client-side WebSocket.
|
class |
WebSocketStream
A stream for
HttpClient WebSocket connection. |
Modifier and Type | Class and Description |
---|---|
class |
NetSocket
Represents a socket-like interface to a TCP connection on either the
client or the server side.
|
class |
NetSocketStream
|
Modifier and Type | Method and Description |
---|---|
ReadStream<T> |
ReadStream.endHandler(Handler<Void> endHandler)
Set an end handler.
|
ReadStream<T> |
ReadStream.exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
ReadStream<T> |
ReadStream.handler(Handler<T> handler)
Set a data handler.
|
static <T> ReadStream |
ReadStream.newInstance(ReadStream arg) |
ReadStream<T> |
ReadStream.pause()
Pause the
ReadSupport . |
ReadStream<T> |
ReadStream.resume()
Resume reading.
|
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 |
Modifier and Type | Class and Description |
---|---|
class |
TestSuiteReport
The test suite reports is basically a stream of events reporting the test suite execution.
|
Modifier and Type | Class and Description |
---|---|
class |
SockJSSocket
You interact with SockJS clients through instances of SockJS socket.
|
Copyright © 2016. All rights reserved.