refactored
This commit is contained in:
+3
-1
@@ -9,11 +9,13 @@ class MsgReceiver(MsgSink):
|
||||
self.filter = filter
|
||||
|
||||
def is_msg(self, msg: MsgContainer):
|
||||
res = False
|
||||
try:
|
||||
data = msg.data.decode(encoding="utf-8")
|
||||
return re.match(self.filter, data)
|
||||
res = re.match(self.filter, data) is not None
|
||||
except UnicodeDecodeError:
|
||||
pass
|
||||
return res
|
||||
|
||||
def on_recv(self, msg: MsgContainer):
|
||||
print(f"{self.name}: {msg}")
|
||||
|
||||
Reference in New Issue
Block a user