154
154
transport.connect("notify::status", self._on_status_change)
155
155
AbstractParser.__init__(self, transport, connect_signals=False)
158
166
self._next_chunk = self.CHUNK_START_LINE
159
167
self._receive_buffer = ""
161
169
self._parser.delimiter = "\r\n"
171
def _on_received(self, transport, buf, length):
163
174
def _on_status_change(self, transport, param):
164
175
status = transport.get_property("status")
165
176
if status == IoStatus.OPEN: