| 28 | """Mixin that adds :class:`Manager` capabilities.""" |
| 29 | |
| 30 | def _init_manager(self, |
| 31 | block_timeout=30 * 60.0, no_join=False, |
| 32 | stdout=None, stderr=None): |
| 33 | # type: (float, bool, TextIO, TextIO) -> None |
| 34 | self.stdout = sys.stdout if stdout is None else stdout |
| 35 | self.stderr = sys.stderr if stderr is None else stderr |
| 36 | self.connerrors = self.app.connection().recoverable_connection_errors |
| 37 | self.block_timeout = block_timeout |
| 38 | self.no_join = no_join |
| 39 | |
| 40 | def remark(self, s, sep='-'): |
| 41 | # type: (str, str) -> None |