aljaz/bitfinex-api-py
1
0
Fork 0
mirror of https://github.com/aljazceru/bitfinex-api-py.git synced 2025-12-19 06:44:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix bug in bfxapi.websocket.subscriptions.

Browse Source
This commit is contained in:
Davide Casale
2023-04-20 01:41:08 +02:00
parent d80b8b8721
commit 1f9d1b719e
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
bfxapi/websocket/client/bfx_websocket_client.py
View File

@@ -107,7 +107,7 @@ class BfxWebSocketClient:
await self.__connect()
#pylint: disable-next=too-many-statements
#pylint: disable-next=too-many-statements,too-many-branches
async def __connect(self):
Reconnection = namedtuple("Reconnection", ["status", "attempts", "timestamp"])
reconnection = Reconnection(status=False, attempts=0, timestamp=None)
@@ -118,6 +118,7 @@ class BfxWebSocketClient:
def _on_wss_timeout():
on_timeout_event.set()
#pylint: disable-next=too-many-branches
async def _connection():
nonlocal reconnection, timer, tasks

2
bfxapi/websocket/subscriptions.py
View File

@@ -12,7 +12,7 @@ __all__ = [
_Header = TypedDict("_Header", { "event": Literal["subscribed"], "channel": str, "chanId": int })
Subscription = Union["Ticker", "Trades", "Book", "Candles", "Status"]
Subscription = Union[_Header, "Ticker", "Trades", "Book", "Candles", "Status"]
class Ticker(TypedDict):
subId: str