Collectors versus Flow.Subscriber

[Alexander Kjäll]

Hi

I have been poking around writing an implementation of ADBA for postgresql
and have a question regarding how 'endless' datastreams should be handled.

To take a concrete case is the feature in postgresql that's called logical
decoding, it lets a user subscribe to the replication stream from the
database.

This isn't a stream that has an end, and by that account it doesn't really
in the stream model with collectors and would maybe fit better with the
Flow.Subscriber model.

Have this usecase been considered and is there a way to implement this that
I haven't seen?

best regards
Alexander Kjäll