(self)
| 23 | self.tag = args['tag'] |
| 24 | |
| 25 | def exec(self): |
| 26 | envelope = self.inp.recv() |
| 27 | if envelope is not None: |
| 28 | self.count += 1 |
| 29 | gbuf = self.global_buf.get() |
| 30 | pbuf = self.parent_buf.get() |
| 31 | buf = self.buf.get() |
| 32 | |
| 33 | # print( |
| 34 | # 'Printer[{}] get msg: {}, with tag: {}, buf(global, parent, local): ({}, {}, {})' |
| 35 | # .format(self.id, envelope.msg['message'], self.tag, gbuf, pbuf, buf)) |
| 36 | else: |
| 37 | assert self.count == 10 |