Skip to content

Commit 7e4a6c8

Browse files
fix: stuff
1 parent d13cfd8 commit 7e4a6c8

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

stream_chat/async_chat/channel.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -216,34 +216,34 @@ async def pin(self, user_id: str) -> StreamResponse:
216216
raise StreamChannelException("user_id must not be empty")
217217

218218
payload = {"set": {"pinned": True}}
219-
return self.client.patch(f"{self.url}/member/{user_id}", data=payload)
219+
return await self.client.patch(f"{self.url}/member/{user_id}", data=payload)
220220

221221
async def unpin(self, user_id: str) -> StreamResponse:
222222
if not user_id:
223223
raise StreamChannelException("user_id must not be empty")
224224

225225
payload = {"set": {"pinned": False}}
226-
return self.client.patch(f"{self.url}/member/{user_id}", data=payload)
226+
return await self.client.patch(f"{self.url}/member/{user_id}", data=payload)
227227

228228
async def archive(self, user_id: str) -> StreamResponse:
229229
if not user_id:
230230
raise StreamChannelException("user_id must not be empty")
231231

232232
payload = {"set": {"archived": True}}
233-
return self.client.patch(f"{self.url}/member/{user_id}", data=payload)
233+
return await self.client.patch(f"{self.url}/member/{user_id}", data=payload)
234234

235235
async def unarchive(self, user_id: str) -> StreamResponse:
236236
if not user_id:
237237
raise StreamChannelException("user_id must not be empty")
238238

239239
payload = {"set": {"archived": False}}
240-
return self.client.patch(f"{self.url}/member/{user_id}", data=payload)
240+
return await self.client.patch(f"{self.url}/member/{user_id}", data=payload)
241241

242242
async def update_member_partial(
243243
self, user_id: str, to_set: Dict = None, to_unset: Iterable[str] = None
244-
) -> Union[StreamResponse, Awaitable[StreamResponse]]:
244+
) -> StreamResponse:
245245
if not user_id:
246246
raise StreamChannelException("user_id must not be empty")
247247

248248
payload = {"set": to_set or {}, "unset": to_unset or []}
249-
return self.client.patch(f"{self.url}/member/{user_id}", data=payload)
249+
return await self.client.patch(f"{self.url}/member/{user_id}", data=payload)

stream_chat/channel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,7 @@ def unarchive(self, user_id: str) -> StreamResponse:
242242

243243
def update_member_partial(
244244
self, user_id: str, to_set: Dict = None, to_unset: Iterable[str] = None
245-
) -> Union[StreamResponse, Awaitable[StreamResponse]]:
245+
) -> StreamResponse:
246246
if not user_id:
247247
raise StreamChannelException("user_id must not be empty")
248248

0 commit comments

Comments
 (0)