andpp/mopidy
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Use re for finding terminator and splitting as it does not assume unicode

Browse Source
This commit is contained in:
Thomas Adamcik 2011-07-07 23:47:28 +02:00
parent 4cd6f5f66c
commit 2449308758
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
mopidy/utils/network.py
View File

@ -120,6 +120,7 @@ class LineProtocol(ThreadingActor):
self.send_lock = threading.Lock()
self.recv_buffer = ''
self.send_buffer = ''
self.terminator_re = re.compile(self.terminator)
def on_line_received(self, line):
"""
@ -152,8 +153,9 @@ class LineProtocol(ThreadingActor):
"""Consume new data and yield any lines found."""
if new_data:
self.recv_buffer += new_data
while self.terminator in self.recv_buffer:
line, self.recv_buffer = self.recv_buffer.split(self.terminator, 1)
while self.terminator_re.search(self.recv_buffer):
line, self.recv_buffer = self.terminator_re.split(
self.recv_buffer, 1)
yield line
def log_raw_data(self, data):