FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
It would be very useful to have this feature!
Here is the async version for the GCP pubsub library that the feature can be based on:
https://github.com/talkiq/gcloud-aio
I would like to use this package with GCP pubsub. The implementation is missing and adding it would be great.