Skip to content
This repository has been archived by the owner on Sep 8, 2024. It is now read-only.

Fix messages clearing in the InterceptAllBusClient #2990

Merged
merged 2 commits into from
Sep 10, 2021
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions test/integrationtests/voight_kampff/features/environment.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,9 +38,9 @@ def create_voight_kampff_logger():


class InterceptAllBusClient(MessageBusClient):
"""Bus Client storing all messages recieved.
"""Bus Client storing all messages received.

This allows readback of older messages and non-event-driven operation.
This allows read back of older messages and non-event-driven operation.
"""
def __init__(self):
super().__init__()
Expand All @@ -50,7 +50,7 @@ def __init__(self):
self._processed_messages = 0

def on_message(self, message):
"""Extends normal operation by storing the recieved message.
"""Extends normal operation by storing the received message.

Args:
message (Message): message from the Mycroft bus
Expand All @@ -64,7 +64,7 @@ def get_messages(self, msg_type):
"""Get messages from received list of messages.

Args:
msg_type (None,str): string filter for messagetype to extract.
msg_type (None,str): string filter for the message type to extract.
if None all messages will be returned.
"""
with self.message_lock:
Expand All @@ -91,9 +91,9 @@ def remove_message(self, msg):
self.messages.remove(msg)

def clear_messages(self):
"""Clear all messages that has been fetched atleast once."""
"""Clear all messages that has been fetched at least once."""
with self.message_lock:
self.messages = self.messages[:self._processed_messages]
self.messages = self.messages[self._processed_messages:]
self._processed_messages = 0

def clear_all_messages(self):
Expand Down