Transient subscription event mapping function

[slashdotdash]

You can provide an event mapping function that maps each EventStore.RecordedEvent before sending it to the subscriber:

EventStore.subscribe(stream_uuid, mapper: fn
  %EventStore.RecordedEvent{data: data} -> data
end)

# receive first batch of mapped event data
receive do
  {:events, event_data} ->
    IO.puts "Received event data: " <> inspect(event_data)
end