diff options
| -rw-r--r-- | src/main/scala/xyz/driver/core/pubsub.scala | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/main/scala/xyz/driver/core/pubsub.scala b/src/main/scala/xyz/driver/core/pubsub.scala index e63217c..d4c0849 100644 --- a/src/main/scala/xyz/driver/core/pubsub.scala +++ b/src/main/scala/xyz/driver/core/pubsub.scala @@ -65,12 +65,12 @@ object pubsub { def stopListening(): Unit } - class GooglePubsubSubscriber[Message, Result](projectId: String, - subscriptionId: String, - receiver: Message => Future[Result], - log: Logger)(implicit messageMarshaller: Unmarshaller[String, Message], - mat: Materializer, - ex: ExecutionContext) + class GooglePubsubSubscriber[Message](projectId: String, + subscriptionId: String, + receiver: Message => Future[Unit], + log: Logger)(implicit messageMarshaller: Unmarshaller[String, Message], + mat: Materializer, + ex: ExecutionContext) extends PubsubSubscriber { private val subscriptionName = SubscriptionName.create(projectId, subscriptionId) |