I would like to use this package with GCP pubsub. The implementation is missing and adding it would be great.