code: def run(self):
      try:
          while self.should_continue_running():
              raw_message = self._ws_client.recv()
              self._abort_message_processor.run(raw_message)
      except WebSocketConnectionClosedException:
          pass
  
file_path: neptune-client/src/neptune/legacy/internal/threads/aborting_thread.py
imports: import threading
  from websocket import WebSocketConnectionClosedException
  from neptune.legacy.internal.threads.neptune_thread import NeptuneThread
  from neptune.legacy.internal.websockets.message import MessageType
  from neptune.legacy.internal.websockets.websocket_message_processor import WebsocketMessageProcessor
label_desc: Use image node_id 2 for calling the AbortingThread obj's underlying member method code with example usage: obj.run() without return types