def callback(self, in_data, count, time_info, status):
if self.pos + count > self.range[1]:
output = self.signal[self.pos:self.range[1], :]
status = pa.paComplete
if self.stop_func: self.stop_func()
else:
output = self.signal[self.pos:self.pos + count, :]
status = pa.paContinue
self.pos += count
return (output.flatten().astype(np.float32).tostring(), status)
评论列表
文章目录