Skip to content

Commit

Permalink
Merge pull request #6 from bplommer/use-blocking-for-flag-lookups
Browse files Browse the repository at this point in the history
Use `Sync.blocking` for flag evaluations
  • Loading branch information
bplommer authored Nov 1, 2022
2 parents c803ca7 + 703f48d commit eebd6eb
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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 =>
Expand Down

0 comments on commit eebd6eb

Please sign in to comment.