Skip to content

Commit 948adf1

Browse files
committed
Fix optional typing issues
1 parent c911a8b commit 948adf1

File tree

6 files changed

+6
-6
lines changed

6 files changed

+6
-6
lines changed

stream_chat/async_chat/channel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ async def hide(self, user_id: str) -> StreamResponse:
195195
async def show(self, user_id: str) -> StreamResponse:
196196
return await self.client.post(f"{self.url}/show", data={"user_id": user_id})
197197

198-
async def mute(self, user_id: str, expiration: int = None) -> StreamResponse:
198+
async def mute(self, user_id: str, expiration: Optional[int] = None) -> StreamResponse:
199199
params: Dict[str, Union[str, int]] = {
200200
"user_id": user_id,
201201
"channel_cid": self.cid,

stream_chat/async_chat/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ async def translate_message(self, message_id: str, language: str) -> StreamRespo
325325
)
326326

327327
async def pin_message(
328-
self, message_id: str, user_id: str, expiration: int = None
328+
self, message_id: str, user_id: str, expiration: Optional[int] = None
329329
) -> StreamResponse:
330330
updates = {
331331
"set": {

stream_chat/base/channel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -420,7 +420,7 @@ def show(self, user_id: str) -> Union[StreamResponse, Awaitable[StreamResponse]]
420420

421421
@abc.abstractmethod
422422
def mute(
423-
self, user_id: str, expiration: int = None
423+
self, user_id: str, expiration: Optional[int] = None
424424
) -> Union[StreamResponse, Awaitable[StreamResponse]]:
425425
"""
426426
Mutes a channel.

stream_chat/base/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -513,7 +513,7 @@ def translate_message(
513513

514514
@abc.abstractmethod
515515
def pin_message(
516-
self, message_id: str, user_id: str, expiration: int = None
516+
self, message_id: str, user_id: str, expiration: Optional[int] = None
517517
) -> Union[StreamResponse, Awaitable[StreamResponse]]:
518518
"""
519519
Pins a message.

stream_chat/channel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ def hide(self, user_id: str) -> StreamResponse:
196196
def show(self, user_id: str) -> StreamResponse:
197197
return self.client.post(f"{self.url}/show", data={"user_id": user_id})
198198

199-
def mute(self, user_id: str, expiration: int = None) -> StreamResponse:
199+
def mute(self, user_id: str, expiration: Optional[int] = None) -> StreamResponse:
200200
params: Dict[str, Union[str, int]] = {
201201
"user_id": user_id,
202202
"channel_cid": self.cid,

stream_chat/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -318,7 +318,7 @@ def commit_message(self, message_id: str) -> StreamResponse:
318318
return self.post(f"messages/{message_id}/commit")
319319

320320
def pin_message(
321-
self, message_id: str, user_id: str, expiration: int = None
321+
self, message_id: str, user_id: str, expiration: Optional[int] = None
322322
) -> StreamResponse:
323323
updates = {
324324
"set": {

0 commit comments

Comments
 (0)