Fix synchronizer lock when creating mutable storage

neo4reo · Sep 24, 2017 · b4b4921 · b4b4921
1 parent 80fea56
commit b4b4921
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/irohad/ametsuchi/impl/storage_impl.cpp b/irohad/ametsuchi/impl/storage_impl.cpp
@@ -101,8 +101,10 @@ namespace iroha {
 
       nonstd::optional<hash256_t> 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<MutableStorageImpl>(
           top_hash.value_or(hash256_t{}),