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).
|
rx.Observable<Void> |
closeObservable()
Deprecated.
use
rxClose() instead |
int |
column(String name)
Will convert the column name to the json array index.
|
ReadStream<JsonArray> |
endHandler(Handler<Void> arg0)
Set an end handler.
|
ReadStream<JsonArray> |
exceptionHandler(Handler<Throwable> arg0)
Set an exception handler on the read stream.
|
SQLRowStream |
getDelegate() |
ReadStream<JsonArray> |
handler(Handler<JsonArray> arg0)
Set a data handler.
|
void |
moreResults()
Request for more results if available
|
static SQLRowStream |
newInstance(SQLRowStream arg) |
ReadStream<JsonArray> |
pause()
Pause the
ReadSupport . |
SQLRowStream |
resultSetClosedHandler(Handler<Void> handler)
Event handler when a resultset is closed.
|
ReadStream<JsonArray> |
resume()
Resume reading.
|
rx.Single<Void> |
rxClose()
Closes the stream/underlying cursor(s).
|
rx.Observable<JsonArray> |
toObservable() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
newInstance, newInstance
newInstance
public static final TypeArg<SQLRowStream> __TYPE_ARG
public SQLRowStream(SQLRowStream delegate)
public SQLRowStream getDelegate()
getDelegate
in interface ReadStream<JsonArray>
getDelegate
in interface StreamBase
public rx.Observable<JsonArray> toObservable()
toObservable
in interface ReadStream<JsonArray>
public ReadStream<JsonArray> exceptionHandler(Handler<Throwable> arg0)
ReadStream
exceptionHandler
in interface ReadStream<JsonArray>
exceptionHandler
in interface StreamBase
arg0
- the exception handlerpublic ReadStream<JsonArray> handler(Handler<JsonArray> arg0)
ReadStream
handler
in interface ReadStream<JsonArray>
public ReadStream<JsonArray> pause()
ReadStream
ReadSupport
. While it's paused, no data will be sent to the dataHandler
pause
in interface ReadStream<JsonArray>
public ReadStream<JsonArray> resume()
ReadStream
ReadSupport
has been paused, reading will recommence on it.resume
in interface ReadStream<JsonArray>
public ReadStream<JsonArray> endHandler(Handler<Void> arg0)
ReadStream
endHandler
in interface ReadStream<JsonArray>
public int column(String name)
name
- the column namepublic SQLRowStream resultSetClosedHandler(Handler<Void> handler)
handler
- public void moreResults()
public void close()
public void close(Handler<AsyncResult<Void>> handler)
handler
- called when the stream/underlying cursor(s) is(are) closed@Deprecated public rx.Observable<Void> closeObservable()
rxClose()
insteadpublic rx.Single<Void> rxClose()
public static SQLRowStream newInstance(SQLRowStream arg)
Copyright © 2017. All rights reserved.