Sha256: 52c946d24af509ac497b1d7362f93b05d49c7efdd3a171951abfcd06f05ec47e

Contents?: true

Size: 1.01 KB

Versions: 7

Compression:

Stored size: 1.01 KB

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