-
Notifications
You must be signed in to change notification settings - Fork 124
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
ListStreams guidance #376
Comments
Yes, that's it. You can stop when the StreamIds array is empty.
…On Thu, Mar 26, 2020 at 12:24 PM James Woodley ***@***.***> wrote:
I've been looking in the docs and can't find reference to the ListStreams
method. Am hoping to find guidance on the correct way to use it, I'm
assuming a while loop to the Next() method was the intention?
Thanks!
—
You are receiving this because you are subscribed to this thread.
Reply to this email directly, view it on GitHub
<#376>, or
unsubscribe
<https://github.com/notifications/unsubscribe-auth/AADY7BZ272SC7TRDHFMB3DDRJM3MJANCNFSM4LUE5IKA>
.
--
Sent from my regular computer
http://twitter.com/thefringeninja
http://www.thefringeninja.com/
|
Perfect thanks! I'm looking for a way to be able to track my observers. How I've currently done it is to set up an AllStreams Subscription on app load that then marshalls events to the appropriate stream observers (there could be many per stream building different read models whatever). I'm then storing the position of my AllStreams sub as well as the individual observer/stream subs in postgres to be able to not have to start them at 0 on every app load. Does that approach make sense? I was experimenting with the ListStreams approach to get everything in the current system and then subscribing to them individually, but that makes it harder to determine what observers need a subscription (in the current thinking, anyway) |
I've been looking in the docs and can't find reference to the ListStreams method. Am hoping to find guidance on the correct way to use it, I'm assuming a while loop to the Next() method was the intention?
Thanks!
The text was updated successfully, but these errors were encountered: