code: def _read_console_output(self, ws, out):
          
  
          while True:
              msg = yield from ws.receive()
              if msg.tp == aiohttp.WSMsgType.text:
                  out.feed_data(msg.data.encode())
              elif msg.tp == aiohttp.WSMsgType.BINARY:
                  out.feed_data(msg.data)
              elif msg.tp == aiohttp.WSMsgType.ERROR:
                  log.critical("Docker WebSocket Error: {}".format(msg.data))
              else:
                  out.feed_eof()
                  ws.close()
                  break
          yield from self.stop()
docs: Read Websocket and forward it to the telnet
  
          :param ws: Websocket connection
          :param out: Output stream