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.

Author:
Pavel Drankou, Thomas Segismont
See Also:
  • ResultSet

  • Field Details

  • Constructor Details

    • ResultSet

      public ResultSet(io.vertx.cassandra.ResultSet delegate)
      Create a new instance of ResultSet delegating to the given (non-null) instance of ResultSet.

    • ResultSet

      public ResultSet(Object delegate)

  • Method Details

    • getDelegate

      public io.vertx.cassandra.ResultSet getDelegate()
      Get the delegate instance.

      This method returns the instance on which this shim is delegating the calls. And so, give you access to the bare API.

      Specified by:
      getDelegate in interface MutinyDelegate
      Returns:
      the delegate instance

    • 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 one(). This may lead to unexpected result.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • ResultSet.all()

    • allAndAwait

      public List<com.datastax.oss.driver.api.core.cql.Row> allAndAwait()
      The method should not be used concurrently with others like fetchNextPage() or one(). This may lead to unexpected result.

      Unlike the bare Vert.x variant, this method returns a List<com.datastax.oss.driver.api.core.cql.Row>. This method awaits indefinitely 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 operation result
      See Also:
      • ResultSet.all()

    • allAndForget

      public ResultSet allAndForget()
      The method should not be used concurrently with others like fetchNextPage() or one(). This may lead to unexpected result.

      Unlike the bare Vert.x variant, this method ignores the List<com.datastax.oss.driver.api.core.cql.Row> result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • ResultSet.all()

    • fetchNextPage

      @CheckReturnValue public io.smallrye.mutiny.Uni<ResultSet> fetchNextPage() throws IllegalStateException

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      Throws:
      IllegalStateException
      See Also:
      • AsyncResultSet#wasApplied()
      • ResultSet.fetchNextPage()

    • fetchNextPageAndAwait

      public ResultSet fetchNextPageAndAwait() throws IllegalStateException

      Unlike the bare Vert.x variant, this method returns a ResultSet. This method awaits indefinitely 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 operation result
      Throws:
      IllegalStateException
      See Also:
      • AsyncResultSet#wasApplied()
      • ResultSet.fetchNextPage()

    • fetchNextPageAndForget

      public ResultSet fetchNextPageAndForget() throws IllegalStateException

      Unlike the bare Vert.x variant, this method ignores the ResultSet result or any failure.

      Returns:
      The current instance to chain operations if needed.
      Throws:
      IllegalStateException
      See Also:
      • AsyncResultSet#wasApplied()
      • ResultSet.fetchNextPage()

    • getColumnDefinitions

      public com.datastax.oss.driver.api.core.cql.ColumnDefinitions getColumnDefinitions()
      See Also:
      • AsyncResultSet#getColumnDefinitions()

    • getExecutionInfo

      public com.datastax.oss.driver.api.core.cql.ExecutionInfo getExecutionInfo()
      See Also:
      • AsyncResultSet#getExecutionInfo()

    • remaining

      public int remaining()
      See Also:
      • AsyncResultSet#remaining()

    • currentPage

      public Iterable<com.datastax.oss.driver.api.core.cql.Row> currentPage()
      See Also:
      • AsyncResultSet#currentPage()

    • one

      public com.datastax.oss.driver.api.core.cql.Row one()
      See Also:
      • AsyncResultSet#one()

    • hasMorePages

      public boolean hasMorePages()
      See Also:
      • AsyncResultSet#hasMorePages()

    • wasApplied

      public boolean wasApplied()
      See Also:
      • AsyncResultSet#wasApplied()

    • newInstance

      public static ResultSet newInstance(io.vertx.cassandra.ResultSet delegate)
      Creates a new instance of the ResultSet.

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

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

    • toString

      public String toString()
      Overrides:
      toString in class Object