Johan Haleby

Add ability to modify all events in an event stream?

1

Function that takes Stream -> Stream

Använd Spring TX för att spara ner subscription position (dvs checkpoint) och en view/projection i samma transaktion! På så vis kan man undvika duplicate events vid retry.

Upcasting etc

Including an example of `foldLeft`

Extract a cache interface and create mongodb/redis implementations. This is crucial if duplicates are not allowed. Cache could be cleared once catch-up phase is over.

Write test that verifies that if two events are written at the same time that the order is preserved

1

i.e e1 and e2 both a t1 then make sure that the order on "read" is always [e1, e2] (good to test this after changing to "id" sorting)

Implement "alarm clock" utility

4

An "alarm clock" would be a place to post stuff like "Notify me in 5 minutes that we need to escalate billing for this particular order". I.e. a message will...

E.g. let's say that you're interested in creating a saga for a specific stream after an event occurs (this is an awkward example, try finding a better one to see...