Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e5d0e91e93 | ||
|
|
e58f0b1d04 |
@@ -27,14 +27,15 @@ class MessageQueueHandler:
|
|||||||
|
|
||||||
def _dispatch_messages(self):
|
def _dispatch_messages(self):
|
||||||
for message in iter(self._queue.get, None):
|
for message in iter(self._queue.get, None):
|
||||||
message['typing'] = not self._queue.empty()
|
is_queue_empty = self._queue.empty()
|
||||||
|
message['typing'] = not is_queue_empty
|
||||||
self.connector.send_message(message)
|
self.connector.send_message(message)
|
||||||
self._sleep(self._get_sleep_time(message))
|
self._sleep(self._get_sleep_time(message, is_queue_empty))
|
||||||
|
|
||||||
def _get_sleep_time(self, message):
|
def _get_sleep_time(self, message, is_queue_empty):
|
||||||
words_per_min = message['wpm'] if 'wpm' in message else self.wpm
|
words_per_min = message['wpm'] if 'wpm' in message else self.wpm
|
||||||
chars_per_min = self.avg_word_len * words_per_min / 60
|
chars_per_min = self.avg_word_len * words_per_min / 60
|
||||||
return len(message['message']) / chars_per_min
|
return 0 if is_queue_empty else len(message['message']) / chars_per_min
|
||||||
|
|
||||||
def _sleep(self, seconds):
|
def _sleep(self, seconds):
|
||||||
poll_freq = self.drain_poll_freq
|
poll_freq = self.drain_poll_freq
|
||||||
|
|||||||
@@ -79,6 +79,7 @@ class IdeHandler:
|
|||||||
def read(self, message):
|
def read(self, message):
|
||||||
if 'patterns' in message:
|
if 'patterns' in message:
|
||||||
self.filemanager.patterns = message['patterns']
|
self.filemanager.patterns = message['patterns']
|
||||||
|
self.monitor.paths = self.filemanager.parents
|
||||||
try:
|
try:
|
||||||
message['filename'] = self.filemanager.find_file(
|
message['filename'] = self.filemanager.find_file(
|
||||||
message.get('filename') or self.initial_file
|
message.get('filename') or self.initial_file
|
||||||
|
|||||||
Reference in New Issue
Block a user