graceful close duplicate incoming notification stream (#1350)

Signed-off-by: turuslan <turuslan.devbox@gmail.com>
qdrvm · Sep 23, 2022 · 610d964 · 610d964
1 parent 60e9e2d
commit 610d964
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/network/impl/stream_engine.hpp b/core/network/impl/stream_engine.hpp
@@ -417,7 +417,11 @@ namespace kagome::network {
       bool replaced = false;
       // Reset previous stream if any
       if (dst) {
-        dst->reset();
+        if (direction == Direction::INCOMING) {
+          dst->close([](outcome::result<void>) {});
+        } else {
+          dst->reset();
+        }
         replaced = true;
       }