public class PgStream<T> extends Object implements io.vertx.reactivex.core.streams.ReadStream<T>
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<PgStream> |
__TYPE_ARG |
io.vertx.lang.rx.TypeArg<T> |
__typeArg_0 |
Constructor and Description |
---|
PgStream(PgStream delegate) |
PgStream(PgStream delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the stream and release the resources.
|
void |
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler)
Close the stream and release the resources.
|
PgStream<T> |
endHandler(io.vertx.core.Handler<Void> endHandler) |
boolean |
equals(Object o) |
PgStream<T> |
exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
io.vertx.reactivex.core.streams.ReadStream<T> |
fetch(long arg0) |
PgStream |
getDelegate() |
PgStream<T> |
handler(io.vertx.core.Handler<T> handler) |
int |
hashCode() |
static <T> PgStream<T> |
newInstance(PgStream arg) |
static <T> PgStream<T> |
newInstance(PgStream arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
PgStream<T> |
pause() |
PgStream<T> |
resume() |
Completable |
rxClose()
Close the stream and release the resources.
|
Flowable<T> |
toFlowable() |
Observable<T> |
toObservable() |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static final io.vertx.lang.rx.TypeArg<PgStream> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<T> __typeArg_0
public PgStream(PgStream delegate)
public PgStream getDelegate()
getDelegate
in interface io.vertx.reactivex.core.streams.ReadStream<T>
getDelegate
in interface io.vertx.reactivex.core.streams.StreamBase
public Observable<T> toObservable()
toObservable
in interface io.vertx.reactivex.core.streams.ReadStream<T>
public Flowable<T> toFlowable()
toFlowable
in interface io.vertx.reactivex.core.streams.ReadStream<T>
public io.vertx.reactivex.core.streams.ReadStream<T> fetch(long arg0)
fetch
in interface io.vertx.reactivex.core.streams.ReadStream<T>
public PgStream<T> exceptionHandler(io.vertx.core.Handler<Throwable> handler)
exceptionHandler
in interface io.vertx.reactivex.core.streams.ReadStream<T>
exceptionHandler
in interface io.vertx.reactivex.core.streams.StreamBase
public PgStream<T> handler(io.vertx.core.Handler<T> handler)
handler
in interface io.vertx.reactivex.core.streams.ReadStream<T>
public PgStream<T> pause()
pause
in interface io.vertx.reactivex.core.streams.ReadStream<T>
public PgStream<T> resume()
resume
in interface io.vertx.reactivex.core.streams.ReadStream<T>
public PgStream<T> endHandler(io.vertx.core.Handler<Void> endHandler)
endHandler
in interface io.vertx.reactivex.core.streams.ReadStream<T>
public void close()
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler)
completionHandler
- the completion handler for this operationpublic Completable rxClose()
Copyright © 2019 Eclipse. All rights reserved.