Package io.vertx.mutiny.cassandra

Class ResultSet

  • public class ResultSet
extends Object
    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.

    • Constructor Detail

      • ResultSet

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

      • ResultSet

        public ResultSet​(Object delegate)

    • Method Detail

      • getDelegate

        public io.vertx.cassandra.ResultSet getDelegate()

      • 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)