code: def _init_stream(self):
          '''Create streams and commander.
  
          Coroutine.
          '''
          assert not self._control_connection
          self._control_connection = yield from self._acquire_request_connection(self._request)
          self._control_stream = ControlStream(self._control_connection)
          self._commander = Commander(self._control_stream)
  
          read_callback = functools.partial(self.event_dispatcher.notify, self.Event.control_receive_data)
          self._control_stream.data_event_dispatcher.add_read_listener(read_callback)
  
          write_callback = functools.partial(self.event_dispatcher.notify, self.Event.control_send_data)
          self._control_stream.data_event_dispatcher.add_write_listener(write_callbackf _init_stream(self):
          '''Create streams and commander.
  
          Coroutine.
          '''
          assert not self._control_connection
          self._control_connection = yield from self._acquire_request_connection(self._request)
          self._control_stream = ControlStream(self._control_connection)
          self._commander = Commander(self._control_stream)
  
          read_callback = functools.partial(self.event_dispatcher.notify, self.Event.control_receive_data)
          self._control_stream.data_event_dispatcher.add_read_listener(read_callback)
  
          write_callback = functools.partial(self.event_dispatcher.notify, self.Event.control_send_data)
          self._control_stream.data_event_dispatcher.add_write_listener(write_callback)
docs: Create streams and commander.
  
          Coroutine.