(self)
| 63 | return self._receive_from_publisher_and_check() |
| 64 | |
| 65 | def receive_sequence(self): |
| 66 | body = self._receive_from_publisher_and_check() |
| 67 | hash = body[:32].hex() |
| 68 | label = chr(body[32]) |
| 69 | mempool_sequence = None if len(body) != 32+1+8 else struct.unpack("<Q", body[32+1:])[0] |
| 70 | if mempool_sequence is not None: |
| 71 | assert label == "A" or label == "R" |
| 72 | else: |
| 73 | assert label == "D" or label == "C" |
| 74 | return (hash, label, mempool_sequence) |
| 75 | |
| 76 | |
| 77 | class ZMQTestSetupBlock: |