Revert #1126 as it's causing a performance regression (#1322)

atnoya · aartigao · web-flow · commit 81bee4e7ce11 · 2024-04-25T09:06:08.000+02:00
Co-authored-by: Alan Artigao Carreño &lt;alanartigao@gmail.com&gt;
diff --git 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] =

Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ private[kafka] trait Blocking[F[_]] {`
`20`	`20`	`private[kafka] object Blocking {`
`21`	`21`
`22`	`22`	`def fromSync[F[_]: Sync]: Blocking[F] = new Blocking[F] {`
`23`		`- override def apply[A](a: => A): F[A] = Sync[F].interruptible(a)`
	`23`	`+ override def apply[A](a: => A): F[A] = Sync[F].blocking(a)`
`24`	`24`	`}`
`25`	`25`
`26`	`26`	`def fromExecutionContext[F[_]](ec: ExecutionContext)(implicit F: Async[F]): Blocking[F] =`