(self, stream, target, tag, patterns=None, outfile=None)
| 98 | class CommandStreamReader(object): |
| 99 | |
| 100 | def __init__(self, stream, target, tag, patterns=None, outfile=None): |
| 101 | self.stream = stream |
| 102 | self.target = target |
| 103 | self.tag = tag |
| 104 | self.lines = [] |
| 105 | self.patterns = patterns or [] |
| 106 | self.outfile = outfile |
| 107 | self.ended = False |
| 108 | |
| 109 | # Empty files that already exist. |
| 110 | if self.outfile != None: |
| 111 | with open(self.outfile, 'w'): pass |
| 112 | |
| 113 | # Read lines from the stream until it ends. |
| 114 | async def _read(self): |
nothing calls this directly
no outgoing calls
no test coverage detected