 public class FutureStream<T> {
     
     private var futures         = [Future<T>]()
+    
     private typealias InFuture  = Future<T> -> Void
     private var saveCompletes   = [InFuture]()
     

        }
    }
    
    public func map<M>(mapping:T -> M) -> Future<M> {
        return self.map(QueueContext.main, mapping)
    }
    
    public func map<M>(executionContext:ExecutionContext, mapping:T -> M) -> Future<M> {
        let promise = Promise<M>()
        return promise.future
    }
    

    public func succes(value:T) {
        let promise = Promise<T>()
        promise.success(value)
        self.write(promise.future)
    }
    
    public func failure(error:NSError) {
        let promise = Promise<T>()
        promise.failure(error)
        self.write(promise.future)
    }
    
    public func write(future:Future<T>) {
        self.futureStream.write(future)
    }
    

