Lines Matching refs:data_consumer
299 def read_until(self, min_num_bytes, ending, timeout=10, data_consumer=None): argument
301 assert data_consumer is None or len(ending) == 1
304 if data_consumer:
305 data_consumer(data)
312 if data_consumer:
313 data_consumer(new_data)
363 def follow(self, timeout, data_consumer=None): argument
365 data = self.read_until(1, b"\x04", timeout=timeout, data_consumer=data_consumer)
455 def exec_raw(self, command, timeout=10, data_consumer=None): argument
457 return self.follow(timeout, data_consumer)
464 def exec_(self, command, data_consumer=None): argument
465 ret, ret_err = self.exec_raw(command, data_consumer=data_consumer)
485 self.exec_(cmd, data_consumer=stdout_write_bytes)
492 self.exec_(cmd, data_consumer=stdout_write_bytes)
499 self.exec_("print(r(%u))" % chunk_size, data_consumer=lambda d: data.extend(d))
728 buf, timeout=None, data_consumer=stdout_write_bytes
769 ret, ret_err = pyb.follow(timeout=None, data_consumer=stdout_write_bytes)