 	/// anywhere else, as it may close unexpectedly.
 	///
 	/// Returns a producer that will complete or error.
-	//TODO: Swift 3 API guidelines?
 	func writeDataFromProducer(_ producer: SignalProducer<Data, NoError>) -> SignalProducer<(), TaskError> {
 		return SignalProducer { observer, disposable in
 			self.group.enter()

	}

	/// Instantiates a new descriptor pair.
	//TODO: Swift 3 API guidelines?
	class func create(_ queue: DispatchQueue, _ group: DispatchGroup) -> Result<Pipe, TaskError> {
		var fildes: [Int32] = [ 0, 0 ]
		if pipe(&fildes) == 0 {

				}

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

