Zergling_man/moment
Zergling_man/moment
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix local echoes not sent if all threads occupied

Browse Source
This commit is contained in:
miruka 2019-04-19 18:29:25 -04:00
parent aa55ffbc6a
commit 99c06e4034
1 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
harmonyqml/backend/client.py
View File

@ -183,7 +183,6 @@ class Client(QObject):
self._last_typing_set[room_id] = (typing, time.time()) self._last_typing_set[room_id] = (typing, time.time())
print("send", typing)
self.net.talk( self.net.talk(
self.nio.room_typing, self.nio.room_typing,
room_id = room_id, room_id = room_id,
@ -193,7 +192,6 @@ class Client(QObject):
@pyqtSlot(str, str) @pyqtSlot(str, str)
@futurize()
def sendMarkdown(self, room_id: str, text: str) -> None: def sendMarkdown(self, room_id: str, text: str) -> None:
html = self.manager.backend.htmlFilter.fromMarkdown(text) html = self.manager.backend.htmlFilter.fromMarkdown(text)
content = { content = {
@ -204,9 +202,16 @@ class Client(QObject):
} }
self.messageAboutToBeSent.emit(room_id, content) self.messageAboutToBeSent.emit(room_id, content)
self.net.talk( # If the thread pool workers are all occupied, and @futurize
self.nio.room_send, # wrapped sendMarkdown, the messageAboutToBeSent signal neccessary
room_id = room_id, # for local echoes would not be sent until a thread is free.
message_type = "m.room.message", @futurize()
content = content, def send(self):
) return self.net.talk(
self.nio.room_send,
room_id = room_id,
message_type = "m.room.message",
content = content,
)
return send(self)