Contents

module PgEventstore
  module Commands
    class RegularStreamReadPaginated < PgEventstore::AbstractCommand
      # _@param_ `stream`
      #
      # _@param_ `options`
      %a{rbs:test:skip} def call: (PgEventstore::Stream stream, ?options: ::Hash[untyped, untyped]) -> ::Enumerator[Array[PgEventstore::Event], void]

      # _@param_ `stream`
      #
      # _@param_ `options`
      def calc_initial_revision: (PgEventstore::Stream stream, ::Hash[untyped, untyped] options) -> Integer

      # _@param_ `events`
      #
      # _@param_ `max_count`
      def end_reached?: (::Array[PgEventstore::Event] events, Integer max_count) -> bool

      # _@param_ `events`
      #
      # _@param_ `revision`
      #
      # _@param_ `direction`
      def calc_next_revision: (::Array[PgEventstore::Event] events, Integer revision, (String | Symbol)? direction) -> Integer

      # _@param_ `direction`
      def forwards?: ((String | Symbol)? direction) -> bool

      def read_cmd: () -> PgEventstore::Commands::Read
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
pg_eventstore-1.3.3	sig/pg_eventstore/commands/regular_stream_read_paginated.rbs
pg_eventstore-1.3.2	sig/pg_eventstore/commands/regular_stream_read_paginated.rbs
pg_eventstore-1.3.1	sig/pg_eventstore/commands/regular_stream_read_paginated.rbs
pg_eventstore-1.3.0	sig/pg_eventstore/commands/regular_stream_read_paginated.rbs
pg_eventstore-1.2.0	sig/pg_eventstore/commands/regular_stream_read_paginated.rbs
pg_eventstore-1.1.5	sig/pg_eventstore/commands/regular_stream_read_paginated.rbs
pg_eventstore-1.1.4	sig/pg_eventstore/commands/regular_stream_read_paginated.rbs