public class SQLRowStream extends Object implements ReadStream<JsonArray>
original non RX-ified interface using Vert.x codegen.| Modifier and Type | Field and Description |
|---|---|
static TypeArg<SQLRowStream> |
__TYPE_ARG |
| Constructor and Description |
|---|
SQLRowStream(SQLRowStream delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Closes the stream/underlying cursor(s).
|
void |
close(Handler<AsyncResult<Void>> handler)
Closes the stream/underlying cursor(s).
|
int |
column(String name)
Will convert the column name to the json array index.
|
List<String> |
columns()
Returns all column names available in the underlying resultset.
|
SQLRowStream |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
boolean |
equals(Object o) |
SQLRowStream |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
SQLRowStream |
getDelegate() |
SQLRowStream |
handler(Handler<JsonArray> handler)
Set a data handler.
|
int |
hashCode() |
void |
moreResults()
Request for more results if available
|
static SQLRowStream |
newInstance(SQLRowStream arg) |
SQLRowStream |
pause()
Pause the
ReadSupport. |
SQLRowStream |
resultSetClosedHandler(Handler<Void> handler)
Event handler when a resultset is closed.
|
SQLRowStream |
resume()
Resume reading.
|
Completable |
rxClose()
Closes the stream/underlying cursor(s).
|
Flowable<JsonArray> |
toFlowable() |
Observable<JsonArray> |
toObservable() |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, waitnewInstance, newInstancenewInstancepublic static final TypeArg<SQLRowStream> __TYPE_ARG
public SQLRowStream(SQLRowStream delegate)
public SQLRowStream getDelegate()
getDelegate in interface ReadStream<JsonArray>getDelegate in interface StreamBasepublic Observable<JsonArray> toObservable()
toObservable in interface ReadStream<JsonArray>public Flowable<JsonArray> toFlowable()
toFlowable in interface ReadStream<JsonArray>public SQLRowStream exceptionHandler(Handler<Throwable> handler)
ReadStreamexceptionHandler in interface ReadStream<JsonArray>exceptionHandler in interface StreamBasehandler - the exception handlerpublic SQLRowStream handler(Handler<JsonArray> handler)
ReadStreamhandler in interface ReadStream<JsonArray>public SQLRowStream pause()
ReadStreamReadSupport. While it's paused, no data will be sent to the dataHandlerpause in interface ReadStream<JsonArray>public SQLRowStream resume()
ReadStreamReadSupport has been paused, reading will recommence on it.resume in interface ReadStream<JsonArray>public SQLRowStream endHandler(Handler<Void> endHandler)
ReadStreamendHandler in interface ReadStream<JsonArray>public int column(String name)
name - the column namepublic List<String> columns()
public SQLRowStream resultSetClosedHandler(Handler<Void> handler)
handler - called when the current result set is closedpublic void moreResults()
public void close()
public void close(Handler<AsyncResult<Void>> handler)
handler - called when the stream/underlying cursor(s) is(are) closedpublic Completable rxClose()
public static SQLRowStream newInstance(SQLRowStream arg)
Copyright © 2017. All rights reserved.