reading logic in muxed_connection

muxer/mplex/muxed_connection.py

@@ -20,6 +20,9 @@ class MuxedConn(IMuxedConn):
         self.streams = {}
         self.stream_queue = asyncio.Queue()
 
+        # The initiator need not read upon construction time.
+        # It should read when the user decides that it wants to read from the constructed stream.
+        if not initiator:
             asyncio.ensure_future(self.handle_incoming())
 
     def close(self):