 						}, failed: { error in
 							observer.sendFailed(error)
 							stdoutAggregatedObserver.sendFailed(error)
-						}, completed: {
-							stdoutAggregatedObserver.sendCompleted()
-						}, interrupted: {
-							stdoutAggregatedObserver.sendInterrupted()
-						}))
+						}, completed: stdoutAggregatedObserver.sendCompleted
+						, interrupted: stdoutAggregatedObserver.sendInterrupted
+						))
 					}
 
 					stderrProducer.startWithSignal { signal, signalDisposable in

						}, failed: { error in
							observer.sendFailed(error)
							stderrAggregatedObserver.sendFailed(error)
						}, completed: {
							stderrAggregatedObserver.sendCompleted()
						}, interrupted: {
							stderrAggregatedObserver.sendInterrupted()
						}))
					}

					task.standardOutput = stdoutPipe.writeHandle

				} else {
					buffer = data
				}
			}, failed: observer.sendFailed
			, completed: {
				observer.sendNext(.aggregated(buffer))
				observer.sendCompleted()
			}, interrupted: observer.sendInterrupted
			))
		}
	}
}
