From 4eb6e3f2433e6216bce2978d2dc6a2c8d225331f Mon Sep 17 00:00:00 2001 From: vlad Date: Fri, 7 Jul 2017 11:37:37 -0700 Subject: Pubsub subscription receiver return type is ignore anyway --- src/main/scala/xyz/driver/core/pubsub.scala | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'src') 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) -- cgit v1.2.3