diff --git a/CHANGELOG.md b/CHANGELOG.md index 13ab378c..3d92bfa0 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ## [Unreleased] - YYYY-MM-DD - TODO replace date after release +### Changed + +- Fixed responsiveness warning: Bifrost monitor uses fromBlockingIterator + ## [v2.0.0-beta5] - 2024-05-08 ### Added diff --git a/brambl-sdk/src/main/scala/co/topl/brambl/monitoring/BifrostMonitor.scala b/brambl-sdk/src/main/scala/co/topl/brambl/monitoring/BifrostMonitor.scala index 9e7cc841..f2193c46 100644 --- a/brambl-sdk/src/main/scala/co/topl/brambl/monitoring/BifrostMonitor.scala +++ b/brambl-sdk/src/main/scala/co/topl/brambl/monitoring/BifrostMonitor.scala @@ -36,7 +36,7 @@ class BifrostMonitor( * @return The infinite stream of block updatess. If startingBlocks was provided, they will be at the front of the stream. */ def monitorBlocks(): Stream[IO, BifrostBlockSync] = Stream.emits(startingBlocks) ++ - Stream.fromIterator[IO](blockIterator, 1).through(pipe) + Stream.fromBlockingIterator[IO](blockIterator, 1).through(pipe) }