@@ -451,15 +451,15 @@ public func launchTask(task: Task, standardInput: SignalProducer<NSData, NoError
451
451
}
452
452
453
453
return SignalProducer { observer, disposable in
454
- func startAggregating( producer: Pipe . ReadProducer , partial : ( NSData ) -> TaskEvent < NSData > ) -> Pipe . ReadProducer {
454
+ func startAggregating( producer: Pipe . ReadProducer , chunk : ( NSData ) -> TaskEvent < NSData > ) -> Pipe . ReadProducer {
455
455
let aggregated = MutableProperty < Aggregation ? > ( nil )
456
456
457
457
producer. startWithSignal { signal, signalDisposable in
458
458
disposable += signalDisposable
459
459
460
460
let aggregate = NSMutableData ( )
461
461
signal. observe ( Observer ( next: { data in
462
- observer. sendNext ( partial ( data) )
462
+ observer. sendNext ( chunk ( data) )
463
463
aggregate. appendData ( data)
464
464
} , failed: { error in
465
465
observer. sendFailed ( error)
@@ -476,8 +476,8 @@ public func launchTask(task: Task, standardInput: SignalProducer<NSData, NoError
476
476
. flatMap ( . Concat) { $0. producer }
477
477
}
478
478
479
- let stdoutAggregated = startAggregating ( stdoutProducer, partial : TaskEvent . StandardOutput)
480
- let stderrAggregated = startAggregating ( stderrProducer, partial : TaskEvent . StandardError)
479
+ let stdoutAggregated = startAggregating ( stdoutProducer, chunk : TaskEvent . StandardOutput)
480
+ let stderrAggregated = startAggregating ( stderrProducer, chunk : TaskEvent . StandardError)
481
481
482
482
rawTask. standardOutput = stdoutPipe. writeHandle
483
483
rawTask. standardError = stderrPipe. writeHandle
0 commit comments