Merge pull request #7 from czeslavo/add-close

Add Close method to transactional publisher
czeslavo · Mar 20, 2020 · 04be856 · 04be856
2 parents 6b4ba83 + 87b043a
commit 04be856
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/firestore/transactional.go b/pkg/firestore/transactional.go
@@ -23,3 +23,7 @@ func NewTransactionalPublisher(config PublisherConfig, tx *firestore.Transaction
 func (p *TransactionalPublisher) Publish(topic string, messages ...*message.Message) error {
 	return p.publisher.PublishInTransaction(topic, p.tx, messages...)
 }
+
+func (p *TransactionalPublisher) Close() error {
+	return p.publisher.Close()
+}