About

This is an akka persistence query implementation for the time_index fork of the akka persistence cassandra plugin, originally written by krasserm.

BUGS

• Write tests for RealTime, FanoutAndMerge, etc. that show that failures on any of the connected streams are propagated.

TODO