From 81bee4e7ce11cf807f0eaf413c3d9c5f61c32f4e Mon Sep 17 00:00:00 2001 From: Adrian Tubio Noya Date: Thu, 25 Apr 2024 08:06:08 +0100 Subject: [PATCH] Revert #1126 as it's causing a performance regression (#1322) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Alan Artigao Carreño --- modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala b/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala index fb87f6ffa..292e3aac8 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala @@ -20,7 +20,7 @@ private[kafka] trait Blocking[F[_]] { private[kafka] object Blocking { def fromSync[F[_]: Sync]: Blocking[F] = new Blocking[F] { - override def apply[A](a: => A): F[A] = Sync[F].interruptible(a) + override def apply[A](a: => A): F[A] = Sync[F].blocking(a) } def fromExecutionContext[F[_]](ec: ExecutionContext)(implicit F: Async[F]): Blocking[F] =