close streams when done reading
Markus Gerstel
3 years ago
131 | 131 | else: |
132 | 132 | if self._closing: |
133 | 133 | break |
134 | self._stream.close() | |
134 | 135 | self._terminated = True |
135 | 136 | la.flush() |
136 | 137 | if self._debug: |
150 | 151 | print(linedecode) |
151 | 152 | if callback: |
152 | 153 | callback(linedecode) |
154 | self._stream.close() | |
153 | 155 | self._terminated = True |
154 | 156 | if self._debug: |
155 | 157 | logger.debug("Stream reader terminated") |