Fix compilation issue in 2.12.x (#131)

evolution-gaming · Jan 7, 2021 · 44d9ce2 · 44d9ce2
1 parent 1d23da1
commit 44d9ce2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/CassandraModule.scala b/...e-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/CassandraModule.scala
@@ -52,7 +52,7 @@ object CassandraModule {
       fromGFuture     = new FromGFuture[F] {
         val self = FromGFuture.lift[F]
         def apply[A](future: => ListenableFuture[A]) = {
-          val fa = self(future) onError { e =>
+          val fa = self(future) onError { case e =>
             log.error("Cassandra request failed", e)
           }
           Concurrent.timeout(fa, FutureTimeout)