diff options
author | vlad <vlad@driver.xyz> | 2017-07-07 11:37:37 -0700 |
---|---|---|
committer | vlad <vlad@driver.xyz> | 2017-07-07 11:37:37 -0700 |
commit | 4eb6e3f2433e6216bce2978d2dc6a2c8d225331f (patch) | |
tree | ce5fdbcbdca15327e3f2e6093c07fa3f0e35373c | |
parent | 26de5937aa1a7c5a8dc17b3bc1a8d9bef6d37fb6 (diff) | |
download | driver-core-4eb6e3f2433e6216bce2978d2dc6a2c8d225331f.tar.gz driver-core-4eb6e3f2433e6216bce2978d2dc6a2c8d225331f.tar.bz2 driver-core-4eb6e3f2433e6216bce2978d2dc6a2c8d225331f.zip |
Pubsub subscription receiver return type is ignore anywayv0.13.19
-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) |