diff --git a/irohad/ametsuchi/impl/storage_impl.cpp b/irohad/ametsuchi/impl/storage_impl.cpp index c1d0d6634f..4e942e05e9 100644 --- a/irohad/ametsuchi/impl/storage_impl.cpp +++ b/irohad/ametsuchi/impl/storage_impl.cpp @@ -101,8 +101,10 @@ namespace iroha { nonstd::optional top_hash; - blocks_->getTopBlocks(1).as_blocking().subscribe( - [&top_hash](auto block) { top_hash = block.hash; }); + blocks_->getTopBlocks(1) + .subscribe_on(rxcpp::observe_on_new_thread()) + .as_blocking() + .subscribe([&top_hash](auto block) { top_hash = block.hash; }); return std::make_unique( top_hash.value_or(hash256_t{}),