How to infinitely stream from Cassandra, assuming some other potentially unknown component writes new entries to the table of interest rather continuously, with alpakka-cassandra?
I could use
unfold basically to create a stream of
CassandraSources that use a prepared statement and that each query for a result set newer than and disjoint from the previous sources…
…plus a mechanism that infinitely retries the query if the result set was empty in order to wait for new entries, and use
flatMapConcat to get one stream.
Or is there already something built-in, or perhaps a trick for the query so that it delivers an infinite stream’ish result set?