Hello, I'd like to write a Bluesky application using Jetstream. To make the problem space more general, I want to build an abstraction around an instance that:
- should be instantiated before use
- should be started and stopped during the program's lifetime
- emits certain events which can be subscribed by the program
what interface should I use for this type of interface? I think an stream is desirable but it doesn't have a lifetime