diff --git a/syndicate/mini/core.py b/syndicate/mini/core.py
index 7da9284..18049a5 100644
--- a/syndicate/mini/core.py
+++ b/syndicate/mini/core.py
@@ -164,7 +164,8 @@ class _StreamConnection(Connection, asyncio.Protocol):
 
     def _disconnect(self):
         if self.stop_signal:
-            self.stop_signal.set_result(True)
+            self.stop_signal.get_loop().call_soon_threadsafe(
+                lambda: self.stop_signal.set_result(True))
 
     async def _create_connection(self, loop):
         raise Exception('subclassresponsibility')