| 47 | |
| 48 | |
| 49 | class MaybeResult(): |
| 50 | def __init__(self, heartbeat, value): |
| 51 | self.heartbeat = heartbeat |
| 52 | self.value = value |
| 53 | |
| 54 | @staticmethod |
| 55 | def create_heartbeat(): |
| 56 | return MaybeResult(True, None) |
| 57 | |
| 58 | @staticmethod |
| 59 | def create_result(value): |
| 60 | return MaybeResult(False, value) |
| 61 | |
| 62 | |
| 63 | def Worker(fn, work_queue, done_queue, |
no outgoing calls
no test coverage detected