[bugfix] Fix blocking implementation for CatsMonadAsyncError (#3309)

softwaremill · Nov 9, 2023 · 271bf2c · 271bf2c
1 parent 2c26873
commit 271bf2c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/integrations/cats-effect/src/main/scala/sttp/tapir/integ/cats/effect/CatsMonadError.scala b/integrations/cats-effect/src/main/scala/sttp/tapir/integ/cats/effect/CatsMonadError.scala
@@ -13,4 +13,5 @@ class CatsMonadError[F[_]](implicit F: Sync[F]) extends MonadError[F] {
   override def suspend[T](t: => F[T]): F[T] = F.defer(t)
   override def flatten[T](ffa: F[F[T]]): F[T] = F.flatten(ffa)
   override def ensure[T](f: F[T], e: => F[Unit]): F[T] = F.guaranteeCase(f)(_ => e)
+  override def blocking[T](t: => T): F[T] = F.blocking(t)
 }
diff --git a/...meria-server/cats/src/main/scala/sttp/tapir/server/armeria/cats/CatsMonadAsyncError.scala b/...meria-server/cats/src/main/scala/sttp/tapir/server/armeria/cats/CatsMonadAsyncError.scala
@@ -9,4 +9,7 @@ import sttp.tapir.integ.cats.effect.CatsMonadError
 private 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 => Some(F.delay(c.cancel()))))
+
+  override def blocking[T](t: => T): F[T] = 
+    F.blocking(t)
 }