Fix how blocking is implemented in CatsMonadAsyncError

softwaremill · Nov 9, 2023 · e0a0f0f · e0a0f0f
1 parent 1dc34c4
commit e0a0f0f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/effects/cats/src/main/scala/sttp/client4/impl/cats/CatsMonadAsyncError.scala b/effects/cats/src/main/scala/sttp/client4/impl/cats/CatsMonadAsyncError.scala
@@ -8,4 +8,7 @@ import sttp.monad.{Canceler, MonadAsyncError}
 class CatsMonadAsyncError[F[_]](implicit F: Async[F]) extends CatsMonadError[F] with MonadAsyncError[F] {
   override def async[T](register: ((Either[Throwable, T]) => Unit) => Canceler): F[T] =
     F.async(cb => F.delay(register(cb)).map(c => F.delay(c.cancel()).some))
+
+  override def blocking[T](t: => T): F[T] =
+    F.blocking(t)
 }