Package io.vertx.mutiny.cassandra

Class ResultSet

java.lang.Object
io.vertx.mutiny.cassandra.ResultSet
All Implemented Interfaces:
MutinyDelegate
public class ResultSet extends Object implements MutinyDelegate
It is like AsyncResultSet, but adapted for Vert.x.

NOTE: This class has been automatically generated from the original non Mutiny-ified interface using Vert.x codegen.

  • Field Details

  • Constructor Details

    • ResultSet

      public ResultSet(io.vertx.cassandra.ResultSet delegate)

    • ResultSet

      public ResultSet(Object delegate)

  • Method Details

    • getDelegate

      public io.vertx.cassandra.ResultSet getDelegate()
      Specified by:
      getDelegate in interface MutinyDelegate
      Returns:
      the delegate used by this Mutiny object of generated type

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • remaining

      public int remaining()
      Returns:

    • hasMorePages

      public boolean hasMorePages()
      Returns:

    • fetchNextPage

      @CheckReturnValue public io.smallrye.mutiny.Uni<ResultSet> fetchNextPage()
      Like fetchNextPage() but with a direct callback.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • fetchNextPageAndAwait

      public ResultSet fetchNextPageAndAwait()
      Blocking variant of fetchNextPage().

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      the ResultSet instance produced by the operation.

    • fetchNextPageAndForget

      public void fetchNextPageAndForget()
      Variant of fetchNextPage() that ignores the result of the operation.

      This method subscribes on the result of fetchNextPage(), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from fetchNextPage() but you don't need to compose it with other operations.

    • wasApplied

      public boolean wasApplied()
      Returns:

    • all

      @CheckReturnValue public io.smallrye.mutiny.Uni<List<com.datastax.oss.driver.api.core.cql.Row>> all()
      The method should not be used concurrently with others like fetchNextPage() or . This may lead to unexpected result.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • allAndAwait

      public List<com.datastax.oss.driver.api.core.cql.Row> allAndAwait()
      Blocking variant of all().

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      the List instance produced by the operation.

    • allAndForget

      public void allAndForget()
      Variant of all() that ignores the result of the operation.

      This method subscribes on the result of all(), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from all() but you don't need to compose it with other operations.

    • getColumnDefinitions

      public com.datastax.oss.driver.api.core.cql.ColumnDefinitions getColumnDefinitions()
      Returns:

    • getExecutionInfo

      public com.datastax.oss.driver.api.core.cql.ExecutionInfo getExecutionInfo()
      Returns:

    • currentPage

      public Iterable<com.datastax.oss.driver.api.core.cql.Row> currentPage()
      Returns:

    • one

      public com.datastax.oss.driver.api.core.cql.Row one()
      Returns:

    • newInstance

      public static ResultSet newInstance(io.vertx.cassandra.ResultSet arg)