Sha256: 9cffa7b865b712f6906cd326c393c2b543652084b61693f718676a9601119615
Contents?: true
Size: 844 Bytes
Versions: 7
Compression:
Stored size: 844 Bytes
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_ `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, (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