What’s the best practice for subscriptions? I’ve currently set up an observer that reads out classes from a cache and processes the events from the All Subscription and dishes them out appropriately. Reason to do this is because my aggregates have a stream per instance. To subscribe to all the streams for each instance would need storing that stream exists somewhere, and recreating the subscription each time you need to.
Using the all subscription means your pointer is the same one for every aggregate. If I add a new observer, it will begin from the point the subscription is at, which is not the point right? How does one deal with this? Always go from StreamPosition.Start in the all subscriber, or is storing a list of subscriptions needed actually the right thing to do here?