(self, stream, regex)
| 270 | return None |
| 271 | |
| 272 | async def extract_services(self, stream, regex): |
| 273 | if not isinstance(stream, CommandStreamReader): |
| 274 | print('Error: extract_services must be passed an instance of a CommandStreamReader.') |
| 275 | sys.exit(1) |
| 276 | |
| 277 | services = [] |
| 278 | while True: |
| 279 | line = await stream.readline() |
| 280 | if line is not None: |
| 281 | service = self.extract_service(line, regex) |
| 282 | if service: |
| 283 | services.append(service) |
| 284 | else: |
| 285 | break |
| 286 | return services |
| 287 | |
| 288 | def register(self, plugin, filename): |
| 289 | if plugin.disabled: |
nothing calls this directly
no test coverage detected