(self)
| 87 | yield WalSegment(seg_path, explicit=False) |
| 88 | |
| 89 | def future_segment_stream(self): |
| 90 | sn = self.segment_number |
| 91 | |
| 92 | if sn is None: |
| 93 | # Can't project from this 'segment'; it's probably |
| 94 | # actually a .history file or something like that. |
| 95 | return |
| 96 | |
| 97 | while True: |
| 98 | sn = sn.next_larger() |
| 99 | segment = self.__class__( |
| 100 | path.join(path.dirname(self.path), |
| 101 | self.tli + sn.log + sn.seg)) |
| 102 | yield segment |
| 103 | |
| 104 | |
| 105 | class WalTransferGroup(object): |