EventStore.read_all_streams_forward
You're seeing just the callback
read_all_streams_forward
, go back to EventStore module for more information.
Specs
read_all_streams_forward( start_version :: non_neg_integer(), count :: non_neg_integer(), opts :: options() ) :: {:ok, [EventStore.RecordedEvent.t()]} | {:error, reason :: term()}
Reads the requested number of events from all streams in the order in which they were originally written.
start_version
optionally, the stream version of the first event to read. Defaults to the beginning of the stream if not set.count
optionally, the maximum number of events to read. Defaults to returning 1,000 events from all streams.opts
an optional keyword list containing:name
the name of the event store if provided tostart_link/1
.timeout
an optional timeout for the database transaction, in milliseconds. Defaults to 15,000ms.