python-okx/okx/websocket/WsPublic.py

21 lines
498 B
Python

from twisted.internet import reactor
from .WsConnectManager import WsConnectManager
class WsPublic(WsConnectManager):
def __init__(self, url):
super().__init__(url, isPrivate=False)
def subscribe(self, params: list, callback):
self.subscribeSocket(params, callback)
def unsubscribe(self, params: list, callback):
self.unsubscribeSocket(params, callback)
def stop(self):
try:
self.close()
finally:
reactor.stop()