Package io.vertx.reactivex.sqlclient

Class Cursor

  • public class Cursor
extends Object
    A cursor that reads progressively rows from the database, it is useful for reading very large result sets.

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

    • Field Detail

      • __TYPE_ARG

        public static final io.vertx.lang.rx.TypeArg<Cursor> __TYPE_ARG

    • Constructor Detail

      • Cursor

        public Cursor​(Cursor delegate)

      • Cursor

        public Cursor​(Object delegate)

    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object

      • getDelegate

        public Cursor getDelegate()

      • read

        public Future<RowSet<Row>> read​(int count)
        Read rows from the cursor, the result is provided asynchronously to the handler.
        Parameters:
        count - the amount of rows to read
        Returns:
        a future notified with the result

      • rxRead

        public Single<RowSet<Row>> rxRead​(int count)
        Read rows from the cursor, the result is provided asynchronously to the handler.
        Parameters:
        count - the amount of rows to read
        Returns:
        a future notified with the result

      • hasMore

        public boolean hasMore()
        Returns true when the cursor has results in progress and the read(int) should be called to retrieve them.
        Returns:
        whether the cursor has more results,

      • close

        public Future<Void> close()
        Release the cursor.

        It should be called for prepared queries executed with a fetch size.

        Returns:

      • rxClose

        public Completable rxClose()
        Release the cursor.

        It should be called for prepared queries executed with a fetch size.

        Returns:

      • isClosed

        public boolean isClosed()
        Returns:
        whether the cursor is closed

      • newInstance

        public static Cursor newInstance​(Cursor arg)