code: def create(self):
      return ReconnectingWebsocket(
          url=self._url,
          oauth2_session=self._session,
          shutdown_event=threading.Event(),
          proxies=self._proxies,
      )
  
imports: import threading
  from typing import Optional
  from requests_oauthlib import OAuth2Session
  from neptune.common.websockets.reconnecting_websocket import ReconnectingWebsocket
label_desc: Use image node_id 2 for calling the WebsocketsFactory obj's underlying member method code with example usage: obj.create() and returns: ReconnectingWebsocket