(self)
| 68 | yield ret |
| 69 | |
| 70 | def get_data_strict(self): |
| 71 | self._fill_buffer() |
| 72 | for dp in self._iter: |
| 73 | self._send(dp) |
| 74 | yield self._recv_filter_none() |
| 75 | self._iter = self.ds.__iter__() # refresh |
| 76 | |
| 77 | # first clear the buffer, then fill |
| 78 | for k in range(self._buffer_size): |
| 79 | dp = self._recv_filter_none() |
| 80 | self._buffer_occupancy -= 1 |
| 81 | if k == self._buffer_size - 1: |
| 82 | self._fill_buffer() |
| 83 | yield dp |
| 84 | |
| 85 | def __iter__(self): |
| 86 | if self._strict: |
no test coverage detected