 				}
 
 				return SignalProducer { observer, disposable in
-					func startAggregating(producer: Pipe.ReadProducer, partial: (NSData) -> TaskEvent<NSData>) -> Pipe.ReadProducer {
+					func startAggregating(producer: Pipe.ReadProducer, chunk: (NSData) -> TaskEvent<NSData>) -> Pipe.ReadProducer {
 						let aggregated = MutableProperty<Aggregation?>(nil)
 
 						producer.startWithSignal { signal, signalDisposable in


							let aggregate = NSMutableData()
							signal.observe(Observer(next: { data in
								observer.sendNext(partial(data))
								aggregate.appendData(data)
							}, failed: { error in
								observer.sendFailed(error)

							.flatMap(.Concat) { $0.producer }
					}

					let stdoutAggregated = startAggregating(stdoutProducer, chunk: TaskEvent.StandardOutput)
					let stderrAggregated = startAggregating(stderrProducer, chunk: TaskEvent.StandardError)

					rawTask.standardOutput = stdoutPipe.writeHandle
					rawTask.standardError = stderrPipe.writeHandle
