ReconnectingWebsocket
Attributes
attributeMAX_RECONNECTS= 5attributeMAX_RECONNECT_SECONDS= 60attributeMIN_RECONNECT_WAIT= 0.1attributeTIMEOUT= 10attributeNO_MESSAGE_RECONNECT_TIMEOUT= 60attributewsOptional[ws.WebSocketClientProtocol]= Noneattributews_state= WSListenerState.INITIALISINGattributemax_queue_size= max_queue_sizeFunctions
func__init__(self, url, path=None, prefix='ws/', is_binary=False, exit_coro=None, https_proxy=None, max_queue_size=100, **kwargs)paramselfparamurlstrparampathOptional[str]= Noneparamprefixstr= 'ws/'paramis_binarybool= Falseparamexit_coro= Noneparamhttps_proxyOptional[str]= Noneparammax_queue_sizeint= 100paramkwargs= {}Returns
Nonefuncjson_dumps(self, msg) -> strparamselfparammsgReturns
strfuncjson_loads(self, msg)paramselfparammsgReturns
Nonefunc__aenter__(self)paramselfReturns
Nonefuncclose(self)paramselfReturns
Nonefunc__aexit__(self, exc_type, exc_val, exc_tb)paramselfparamexc_typeparamexc_valparamexc_tbReturns
Nonefuncconnect(self)paramselfReturns
Nonefunc_kill_read_loop(self)paramselfReturns
Nonefunc_before_connect(self)paramselfReturns
Nonefunc_after_connect(self)paramselfReturns
Nonefunc_handle_message(self, evt)paramselfparamevtReturns
Nonefunc_read_loop(self)paramselfReturns
Nonefunc_run_reconnect(self)paramselfReturns
Nonefuncrecv(self)paramselfReturns
Nonefunc_wait_for_reconnect(self)paramselfReturns
Nonefunc_get_reconnect_wait(self, attempts) -> intparamselfparamattemptsintReturns
intfuncbefore_reconnect(self)paramselfReturns
Nonefunc_reconnect(self)paramselfReturns
None