Skip to content

Commit ddb29a7

Browse files
committed
fix sub errors
1 parent 8b5a05f commit ddb29a7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

poloniex/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -716,7 +716,7 @@ def _getChannelName(self, id):
716716

717717
def on_open(self, *ws):
718718
for chan in self.channels:
719-
if self.channels[chan]['sub']:
719+
if 'sub' in self.channels[chan] and self.channels[chan]['sub']:
720720
self.subscribe(chan)
721721

722722
def on_message(self, data):
@@ -855,7 +855,7 @@ def stopws(self, wait=1):
855855
self._running = False
856856
# unsubscribe from subs
857857
for chan in self.channels:
858-
if 'sub' in self.channels[chan] and self.channels[chan]['sub'] == True:
858+
if 'sub' in self.channels[chan] and self.channels[chan]['sub']:
859859
self.unsubscribe(chan)
860860
sleep(wait)
861861
try:

0 commit comments

Comments
 (0)