public class ServerWebSocketStream extends Object implements ReadStream<ServerWebSocket>
ReadStream of ServerWebSocket, used for
notifying web socket connections to a HttpServer.
NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.| Constructor and Description |
|---|
ServerWebSocketStream(ServerWebSocketStream delegate) |
| Modifier and Type | Method and Description |
|---|---|
ServerWebSocketStream |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
ServerWebSocketStream |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
Object |
getDelegate() |
ServerWebSocketStream |
handler(Handler<ServerWebSocket> handler)
Set a data handler.
|
static ServerWebSocketStream |
newInstance(ServerWebSocketStream arg) |
ServerWebSocketStream |
pause()
Pause the
ReadSupport. |
ServerWebSocketStream |
resume()
Resume reading.
|
rx.Observable<ServerWebSocket> |
toObservable() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitnewInstancenewInstancepublic ServerWebSocketStream(ServerWebSocketStream delegate)
public Object getDelegate()
getDelegate in interface ReadStream<ServerWebSocket>getDelegate in interface StreamBasepublic rx.Observable<ServerWebSocket> toObservable()
toObservable in interface ReadStream<ServerWebSocket>public ServerWebSocketStream exceptionHandler(Handler<Throwable> handler)
ReadStreamexceptionHandler in interface ReadStream<ServerWebSocket>exceptionHandler in interface StreamBasehandler - the exception handlerpublic ServerWebSocketStream handler(Handler<ServerWebSocket> handler)
ReadStreamhandler in interface ReadStream<ServerWebSocket>public ServerWebSocketStream pause()
ReadStreamReadSupport. While it's paused, no data will be sent to the dataHandlerpause in interface ReadStream<ServerWebSocket>public ServerWebSocketStream resume()
ReadStreamReadSupport has been paused, reading will recommence on it.resume in interface ReadStream<ServerWebSocket>public ServerWebSocketStream endHandler(Handler<Void> endHandler)
ReadStreamendHandler in interface ReadStream<ServerWebSocket>public static ServerWebSocketStream newInstance(ServerWebSocketStream arg)
Copyright © 2015. All rights reserved.