make Async.async(..) safe in CE 3.5

evolution-gaming · Jan 31, 2024 · 38119a6 · 38119a6
1 parent fe2e1db
commit 38119a6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/Consumer.scala b/skafka/src/main/scala/com/evolutiongaming/skafka/consumer/Consumer.scala
@@ -311,7 +311,7 @@ object Consumer {
                 }
               }
             }
-            Sync[F].blocking(f(offsetCommitCallback)).as(None)
+            Sync[F].blocking(f(offsetCommitCallback)).as(Applicative[F].unit.some)
           }
       }