From 2fb7490bf9bd629eb046ee87d5b0d282bf56f71f Mon Sep 17 00:00:00 2001
From: Gleb Natapov <gleb@cloudius-systems.com>
Date: Mon, 29 Dec 2014 15:17:34 +0200
Subject: [PATCH] stream: reset subscription's stream pointer in stream's
 destructor

---
 core/stream.hh | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/core/stream.hh b/core/stream.hh
index 9376c0f378..c6d385a5a5 100644
--- a/core/stream.hh
+++ b/core/stream.hh
@@ -41,6 +41,7 @@ public:
     stream() = default;
     stream(const stream&) = delete;
     stream(stream&&) = delete;
+    ~stream();
     void operator=(const stream&) = delete;
     void operator=(stream&&) = delete;
 
@@ -93,6 +94,15 @@ public:
     friend class stream<T...>;
 };
 
+
+template <typename... T>
+inline
+stream<T...>::~stream() {
+    if (_sub) {
+        _sub->_stream = nullptr;
+    }
+}
+
 template <typename... T>
 inline
 subscription<T...>