| Package | Description | 
|---|---|
| io.vertx.rxjava.cassandra | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<ResultSet> | 
ResultSet.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
ResultSet | 
ResultSet.all()
The method should not be used concurrently with others like  
fetchNextPage(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.cassandra.ResultSet>>) or . | 
ResultSet | 
ResultSet.all(Handler<AsyncResult<List<com.datastax.oss.driver.api.core.cql.Row>>> handler)
The method should not be used concurrently with others like  
fetchNextPage(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.cassandra.ResultSet>>) or . | 
static ResultSet | 
ResultSet.newInstance(ResultSet arg)  | 
| Modifier and Type | Method and Description | 
|---|---|
Single<ResultSet> | 
CassandraClient.rxExecute(com.datastax.oss.driver.api.core.cql.Statement statement)
Execute the statement and provide a handler for consuming results. 
 | 
Single<ResultSet> | 
CassandraClient.rxExecute(String query)
Execute the query and provide a handler for consuming results. 
 | 
Single<ResultSet> | 
ResultSet.rxFetchNextPage()
Like  
fetchNextPage(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.cassandra.ResultSet>>) but with a direct callback. | 
| Modifier and Type | Method and Description | 
|---|---|
CassandraClient | 
CassandraClient.execute(com.datastax.oss.driver.api.core.cql.Statement statement,
       Handler<AsyncResult<ResultSet>> resultHandler)
Execute the statement and provide a handler for consuming results. 
 | 
CassandraClient | 
CassandraClient.execute(String query,
       Handler<AsyncResult<ResultSet>> resultHandler)
Execute the query and provide a handler for consuming results. 
 | 
void | 
ResultSet.fetchNextPage(Handler<AsyncResult<ResultSet>> handler)
Like  
fetchNextPage(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.cassandra.ResultSet>>) but with a direct callback. | 
Copyright © 2024 Eclipse. All rights reserved.