Sha256: a2c66baeb727a5ddd43a43f044ca7e2e6ca0bd488d848ed99f29130cd29edbf9
Contents?: true
Size: 807 Bytes
Versions: 7
Compression:
Stored size: 807 Bytes
Contents
module PgEventstore
module Commands
class SystemStreamReadPaginated < 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_ `direction`
def calc_next_position: (::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