diff options
| -rw-r--r-- | src/main/scala/xyz/driver/core/pubsub.scala | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/main/scala/xyz/driver/core/pubsub.scala b/src/main/scala/xyz/driver/core/pubsub.scala index 4853c35..ee84328 100644 --- a/src/main/scala/xyz/driver/core/pubsub.scala +++ b/src/main/scala/xyz/driver/core/pubsub.scala @@ -59,9 +59,11 @@ object pubsub { def stopListening(): Unit } - class GooglePubsubSubscriber[T](projectId: String, subscriptionId: String, receiver: String => Future[T], log: Logger)( - implicit ex: ExecutionContext) - extends PubsubSubscriber { + class GooglePubsubSubscriber[T](projectId: String, + subscriptionId: String, + receiver: String => Future[T], + log: Logger)(implicit ex: ExecutionContext) + extends PubsubSubscriber { private val subscriptionName = SubscriptionName.create(projectId, subscriptionId) |