Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Cursor> |
__TYPE_ARG |
Constructor and Description |
---|
Cursor(Cursor delegate) |
Cursor(Object delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Like
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with a completionHandler called when the cursor has been released. |
void |
close(Handler<AsyncResult<Void>> completionHandler)
Like
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with a completionHandler called when the cursor has been released. |
boolean |
equals(Object o) |
Cursor |
getDelegate() |
int |
hashCode() |
boolean |
hasMore()
Returns
true when the cursor has results in progress and the read(int, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.sqlclient.RowSet<io.vertx.rxjava.sqlclient.Row>>>) should be called to retrieve
them. |
boolean |
isClosed() |
static Cursor |
newInstance(Cursor arg) |
void |
read(int count)
Read rows from the cursor, the result is provided asynchronously to the
handler . |
void |
read(int count,
Handler<AsyncResult<RowSet<Row>>> handler)
Read rows from the cursor, the result is provided asynchronously to the
handler . |
Single<Void> |
rxClose()
Like
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but with a completionHandler called when the cursor has been released. |
Single<RowSet<Row>> |
rxRead(int count)
Read rows from the cursor, the result is provided asynchronously to the
handler . |
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<Cursor> __TYPE_ARG
public Cursor getDelegate()
public void read(int count, Handler<AsyncResult<RowSet<Row>>> handler)
handler
.count
- the amount of rows to readhandler
- the handler for the resultpublic void read(int count)
handler
.count
- the amount of rows to readpublic Single<RowSet<Row>> rxRead(int count)
handler
.count
- the amount of rows to readpublic boolean hasMore()
true
when the cursor has results in progress and the read(int, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.sqlclient.RowSet<io.vertx.rxjava.sqlclient.Row>>>)
should be called to retrieve
them.public void close(Handler<AsyncResult<Void>> completionHandler)
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but with a completionHandler
called when the cursor has been released.completionHandler
- public void close()
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but with a completionHandler
called when the cursor has been released.public Single<Void> rxClose()
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but with a completionHandler
called when the cursor has been released.public boolean isClosed()
Copyright © 2021 Eclipse. All rights reserved.