Use Sync.blocking for flag evaluations

typelevel · Nov 1, 2022 · 703f48d · 703f48d
1 parent c803ca7
commit 703f48d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/io/github/bplommer/launchcatsly/LaunchDarklyClient.scala b/core/src/main/scala/io/github/bplommer/launchcatsly/LaunchDarklyClient.scala
@@ -52,7 +52,7 @@ object LaunchDarklyClient {
         new LaunchDarklyClient.Default[F] {
 
           override def unsafeWithJavaClient[A](f: LDClient => A): F[A] =
-            F.delay(f(ldClient))
+            F.blocking(f(ldClient))
 
           override def listen(featureKey: String, user: LDUser): Stream[F, FlagValueChangeEvent] =
             Stream.eval(F.delay(ldClient.getFlagTracker)).flatMap { tracker =>