Fix compilation after #1340 merge

fd4s · Oct 8, 2024 · 714550e · 714550e
1 parent 2441b86
commit 714550e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala b/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala
@@ -190,7 +190,7 @@ object KafkaProducer {
             Async[F]
               .race(
                 Async[F]
-                  .fromFutureCancelable(Async[F].delay(produceRecordError.future, Async[F].unit)),
+                  .fromFutureCancelable(Async[F].delay((produceRecordError.future, Async[F].unit))),
                 produceRecords(produceRecordError.some)
               )
               .rethrow

diff --git a/modules/core/src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala b/modules/core/src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala
@@ -163,7 +163,7 @@ object TransactionalKafkaProducer {
                       Async[F]
                         .race(
                           Async[F].fromFutureCancelable(
-                            Async[F].delay(produceRecordError.future, Async[F].unit)
+                            Async[F].delay((produceRecordError.future, Async[F].unit))
                           ),
                           produceRecords(produceRecordError.some)
                         )