     
     public init(capacity:Int?=nil) {
         self.capacity = capacity
-        self.futureQueue = Queue.simpleFutureStreams
-    }
-
-    public init(queue:Queue, capacity:Int?=nil) {
-        self.capacity = capacity
-        self.futureQueue = queue
-    }
-
-    // should be future mixin
+    }
+
     internal func complete(result:Try<T>) {
         let future = Future<T>()
         future.complete(result)

        self.future = Future<T>()
    }

    public init(queue:Queue) {
        self.future = Future<T>(queue:queue)
    }

    public func completeWith(future:Future<T>) {
        self.completeWith(self.future.defaultExecutionContext, future:future)
    }

        self.future = FutureStream<T>(capacity:capacity)
    }
    
    public func complete(result:Try<T>) {
        self.future.complete(result)
    }
