Package | Description |
---|---|
io.vertx.rxjava.core.datagram |
Modifier and Type | Field and Description |
---|---|
static TypeArg<DatagramPacket> |
DatagramPacket.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
static DatagramPacket |
DatagramPacket.newInstance(io.vertx.core.datagram.DatagramPacket arg) |
Modifier and Type | Method and Description |
---|---|
Pipe<DatagramPacket> |
DatagramSocket.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
rx.Observable<DatagramPacket> |
DatagramSocket.toObservable() |
Modifier and Type | Method and Description |
---|---|
DatagramSocket |
DatagramSocket.handler(io.vertx.core.Handler<DatagramPacket> handler) |
void |
DatagramSocket.pipeTo(WriteStream<DatagramPacket> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
DatagramSocket.pipeTo(WriteStream<DatagramPacket> dst,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream . |
rx.Observable<Void> |
DatagramSocket.pipeToObservable(WriteStream<DatagramPacket> dst)
|
rx.Single<Void> |
DatagramSocket.rxPipeTo(WriteStream<DatagramPacket> dst)
Pipe this
ReadStream to the WriteStream . |
Copyright © 2019 Eclipse. All rights reserved.