Minor typo
This commit is contained in:
+3
-3
@@ -1,9 +1,9 @@
|
|||||||
import re
|
import re
|
||||||
from asyncio import Task
|
|
||||||
from time import sleep
|
from time import sleep
|
||||||
from typing import Any, Optional, Generator, Match, Callable, List, Coroutine, AsyncGenerator
|
from typing import Any, Optional, Generator, Match, Callable, List, Coroutine
|
||||||
|
|
||||||
from slackclient import SlackClient
|
from slackclient import SlackClient
|
||||||
|
from slackclient.client import SlackNotConnected
|
||||||
|
|
||||||
import channel_util
|
import channel_util
|
||||||
|
|
||||||
@@ -79,7 +79,7 @@ def message_stream(slack: SlackClient) -> Generator[dict, None, None]:
|
|||||||
for item in update:
|
for item in update:
|
||||||
if item.get('type') == 'message':
|
if item.get('type') == 'message':
|
||||||
yield item
|
yield item
|
||||||
except OSError as e:
|
except (SlackNotConnected, OSError) as e:
|
||||||
print("Error while reading messages:")
|
print("Error while reading messages:")
|
||||||
print(e)
|
print(e)
|
||||||
except (ValueError, TypeError):
|
except (ValueError, TypeError):
|
||||||
|
|||||||
Reference in New Issue
Block a user