Show More
@@ -276,7 +276,7 b' class BufferedGenerator():' | |||||
276 | return self.data[i] |
|
276 | return self.data[i] | |
277 |
|
277 | |||
278 |
|
278 | |||
279 | class SubprocessIOChunker(): |
|
279 | class SubprocessIOChunker(object): | |
280 | ''' |
|
280 | ''' | |
281 | Processor class wrapping handling of subprocess IO. |
|
281 | Processor class wrapping handling of subprocess IO. | |
282 |
|
282 | |||
@@ -321,7 +321,7 b' class SubprocessIOChunker():' | |||||
321 |
|
321 | |||
322 | ''' |
|
322 | ''' | |
323 | def __init__(self, cmd, inputstream=None, buffer_size=65536, |
|
323 | def __init__(self, cmd, inputstream=None, buffer_size=65536, | |
324 | chunk_size=4096, starting_values=[]): |
|
324 | chunk_size=4096, starting_values=[], **kwargs): | |
325 | ''' |
|
325 | ''' | |
326 | Initializes SubprocessIOChunker |
|
326 | Initializes SubprocessIOChunker | |
327 |
|
327 | |||
@@ -342,7 +342,8 b' class SubprocessIOChunker():' | |||||
342 | shell=True, |
|
342 | shell=True, | |
343 | stdin=inputstream, |
|
343 | stdin=inputstream, | |
344 | stdout=subprocess.PIPE, |
|
344 | stdout=subprocess.PIPE, | |
345 | stderr=subprocess.PIPE |
|
345 | stderr=subprocess.PIPE, | |
|
346 | **kwargs | |||
346 | ) |
|
347 | ) | |
347 |
|
348 | |||
348 | bg_out = BufferedGenerator(_p.stdout, buffer_size, chunk_size, starting_values) |
|
349 | bg_out = BufferedGenerator(_p.stdout, buffer_size, chunk_size, starting_values) |
General Comments 0
You need to be logged in to leave comments.
Login now