(self, idx)
| 54 | return self |
| 55 | |
| 56 | def fetch(self, idx): |
| 57 | """ |
| 58 | """ |
| 59 | outputs = [] |
| 60 | for pkt in self.impl.fetch(idx): |
| 61 | if self.otypes[idx] is None: |
| 62 | outputs.append(pkt) |
| 63 | else: |
| 64 | outputs.append(pkt.get(self.otypes[idx])) |
| 65 | return outputs |
| 66 | |
| 67 | |
| 68 | def make_sync_func(name: str, |