Lines Matching refs:data_consumer
307 def read_until(self, min_num_bytes, ending, timeout=10, data_consumer=None): argument
309 assert data_consumer is None or len(ending) == 1
312 if data_consumer:
313 data_consumer(data)
320 if data_consumer:
321 data_consumer(new_data)
393 def follow(self, timeout, data_consumer=None): argument
395 data = self.read_until(1, b"\x04", timeout=timeout, data_consumer=data_consumer)
483 def exec_raw(self, command, timeout=10, data_consumer=None): argument
485 return self.follow(timeout, data_consumer)
492 def exec_(self, command, data_consumer=None): argument
493 ret, ret_err = self.exec_raw(command, data_consumer=data_consumer)
514 self.exec_(cmd, data_consumer=stdout_write_bytes)
521 self.exec_(cmd, data_consumer=stdout_write_bytes)
528 self.exec_("print(r(%u))" % chunk_size, data_consumer=lambda d: data.extend(d))
730 buf, timeout=None, data_consumer=stdout_write_bytes
768 ret, ret_err = pyb.follow(timeout=None, data_consumer=stdout_write_bytes)