code: def clear_message_streams(self):
          
          for client in self._clients:
              client.empty()
          for server in self._servers:
              server.empty()
docs: Resets streams and sockets of incoming messages.
  
          You can use this method to reuse the same connections for several
          consecutive test cases.