Skip to content
This repository was archived by the owner on Feb 20, 2026. It is now read-only.
This repository was archived by the owner on Feb 20, 2026. It is now read-only.

Add streaming interface for pubsub publishers #61

@lthibault

Description

@lthibault

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 may be worthwhile to reuse code from #59.

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions