You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Feb 20, 2026. It is now read-only.
It is common for pubsub.Topic.Publish() to be called repeatedly in order to stream events to a topic. However, this method blocks until the RPC call round-trips, which degrades performance. While we currently expose PublishAsync, the proper management of stream state is a non-trivial task, so we should expose a NewStream() method that integrates with CASM's pkg/util/stream.
It is common for
pubsub.Topic.Publish()to be called repeatedly in order to stream events to a topic. However, this method blocks until the RPC call round-trips, which degrades performance. While we currently exposePublishAsync, the proper management of stream state is a non-trivial task, so we should expose aNewStream()method that integrates with CASM'spkg/util/stream.It may be worthwhile to reuse code from #59.