View Source
MessageStore
(message_store v3.2.0)
A module for interactions with message store
@spec fetch(
conn,
String.t(),
m,
read:
(conn, String.t(), list() ->
Result.t(reason, [EventStore.RecordedEvent.t()])),
project: ([EventStore.RecordedEvent.t()], m -> projection)
) :: Result.t(reason, projection)
when conn: module(), m: module(), reason: term(), projection: any()
@spec to_result(:ok | {:error, err}, value) :: Result.t(err, value)
when err: any(), value: any()