 							.flatMap(.Concat) { $0.producer }
 					}
 
-					let stdoutAggregated = startAggregating(stdoutProducer, partial: TaskEvent.StandardOutput)
-					let stderrAggregated = startAggregating(stderrProducer, partial: TaskEvent.StandardError)
+					let stdoutAggregated = startAggregating(stdoutProducer, chunk: TaskEvent.StandardOutput)
+					let stderrAggregated = startAggregating(stderrProducer, chunk: TaskEvent.StandardError)
 
 					rawTask.standardOutput = stdoutPipe.writeHandle
 					rawTask.standardError = stderrPipe.writeHandle


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

				}

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

						producer.startWithSignal { signal, signalDisposable in
