Minor refactoring. Make stop_stream also close the associated file descriptor.
This commit is contained in:
parent
f93a621856
commit
31a092f6b4
|
@ -1439,13 +1439,13 @@ class FlowMaster(controller.Master):
|
|||
for i in self.state._flow_list:
|
||||
if not i.response:
|
||||
self.stream.add(i)
|
||||
self.stream.fo.close()
|
||||
self.stop_stream()
|
||||
|
||||
def start_stream(self, fp):
|
||||
self.stream = FlowWriter(fp)
|
||||
|
||||
def stop_stream(self):
|
||||
self.stream.fo.close()
|
||||
self.stream = None
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue