private var _queue: Queue<I> = Queue(capacity: 0)

    private var _queue: Queue<I> = Queue(capacity: 0)

        _queue = Queue(capacity: 0)

    typealias ScheduleQueue = RxMutableBox<Queue<ScheduledItemType>>

        let queue: RxMutableBox<Queue<ScheduledItemType>>

            queue = RxMutableBox(Queue<ScheduledItemType>(capacity: 1))

    typealias QueueType = Queue<S>

    var _queue = Queue<Event<E>>(capacity: 10)

    private var _queue: Queue<Element>

        _queue = Queue(capacity: queueSize + 1)

        _queue = Queue(capacity: 0)

    private var _elements: Queue<ElementType>

        _elements = Queue<ElementType>(capacity: parent._count + 1)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values6: Queue<E6> = Queue(capacity: 2)

    var _values6: Queue<E6> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values6: Queue<E6> = Queue(capacity: 2)

    var _values6: Queue<E6> = Queue(capacity: 2)

    var _values7: Queue<E7> = Queue(capacity: 2)

    var _values7: Queue<E7> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values1: Queue<E1> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values2: Queue<E2> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values3: Queue<E3> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values4: Queue<E4> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values5: Queue<E5> = Queue(capacity: 2)

    var _values6: Queue<E6> = Queue(capacity: 2)

    var _values6: Queue<E6> = Queue(capacity: 2)

    var _values7: Queue<E7> = Queue(capacity: 2)

    var _values7: Queue<E7> = Queue(capacity: 2)

    var _values8: Queue<E8> = Queue(capacity: 2)

    var _values8: Queue<E8> = Queue(capacity: 2)

    private var _values: [Queue<SourceElement>]

        _values = [Queue<SourceElement>](count: parent.count, repeatedValue: Queue(capacity: 4))

        _values = [Queue<SourceElement>](count: parent.count, repeatedValue: Queue(capacity: 4))

    public typealias Generator = AnyGenerator<T>

    private var _storage: ContiguousArray<T?>

            _storage = ContiguousArray<T?>(count: capacity, repeatedValue: nil)

            _storage = ContiguousArray<T?>()

    public func peek() -> T {

        var newStorage = ContiguousArray<T?>(count: size, repeatedValue: nil)

    public mutating func enqueue(element: T) {

    private mutating func dequeueElementOnly() -> T {

    public mutating func dequeue() -> T? {

    public func generate() -> Generator {

            resizeTo(max(_storage.count, 1) * _resizeFactor)

        let downsizeLimit = _storage.count / (_resizeFactor * _resizeFactor)

        let downsizeLimit = _storage.count / (_resizeFactor * _resizeFactor)

            resizeTo(_storage.count / _resizeFactor)

            _storage = ContiguousArray<T?>(count: capacity, repeatedValue: nil)

            _storage = ContiguousArray<T?>()

            return index < 0 ? index + _storage.count : index

        return _storage[dequeueIndex]!

        let spaceToEndOfQueue = _storage.count - dequeueIndex

        newStorage[0 ..< countElementsInFirstBatch] = _storage[dequeueIndex ..< (dequeueIndex + countElementsInFirstBatch)]

        newStorage[countElementsInFirstBatch ..< (countElementsInFirstBatch + numberOfElementsInSecondBatch)] = _storage[0 ..< numberOfElementsInSecondBatch]

        _storage = newStorage

        if count == _storage.count {

            resizeTo(max(_storage.count, 1) * _resizeFactor)

        _storage[_pushNextIndex] = element

        if _pushNextIndex >= _storage.count {

            _pushNextIndex -= _storage.count

        let value = _storage[index]!

        _storage[index] = nil

        let downsizeLimit = _storage.count / (_resizeFactor * _resizeFactor)

            resizeTo(_storage.count / _resizeFactor)

            if i >= self._storage.count {

                i -= self._storage.count

            let element = self._storage[i]

        _count = 0

            return _count

        let count = _count

        _count = count

        _count = _count + 1

        _count = _count + 1

        _count = _count - 1

        _count = _count - 1

        if _count < downsizeLimit && downsizeLimit >= _initialCapacity {

        var count = _count

        _pushNextIndex = 0

           let index = _pushNextIndex - count

        _pushNextIndex = count

        _storage[_pushNextIndex] = element

        _pushNextIndex += 1

        if _pushNextIndex >= _storage.count {

            _pushNextIndex -= _storage.count

        _initialCapacity = capacity

        if _count < downsizeLimit && downsizeLimit >= _initialCapacity {

        return _storage[dequeueIndex]!

        let dequeueIndex = self.dequeueIndex

        let index = dequeueIndex

        var i = dequeueIndex

            if _queue.count > 0 {

            if self._queue.count > 0 {

            if self._queue.count > 0 {

           let index = _pushNextIndex - count

            return count == 0

        precondition(count > 0)

        if count == _storage.count {

        precondition(count > 0)

        if self.count == 0 {

        while _queue.count > _bufferSize {

            if _elements.count > self._parent._count {

        case 0: return _values1.count > 0

        case 1: return _values2.count > 0

        case 0: return _values1.count > 0

        case 1: return _values2.count > 0

        case 2: return _values3.count > 0

        case 0: return _values1.count > 0

        case 1: return _values2.count > 0

        case 2: return _values3.count > 0

        case 3: return _values4.count > 0

        case 0: return _values1.count > 0

        case 1: return _values2.count > 0

        case 2: return _values3.count > 0

        case 3: return _values4.count > 0

        case 4: return _values5.count > 0

        case 0: return _values1.count > 0

        case 1: return _values2.count > 0

        case 2: return _values3.count > 0

        case 3: return _values4.count > 0

        case 4: return _values5.count > 0

        case 5: return _values6.count > 0

        case 0: return _values1.count > 0

        case 1: return _values2.count > 0

        case 2: return _values3.count > 0

        case 3: return _values4.count > 0

        case 4: return _values5.count > 0

        case 5: return _values6.count > 0

        case 6: return _values7.count > 0

        case 0: return _values1.count > 0

        case 1: return _values2.count > 0

        case 2: return _values3.count > 0

        case 3: return _values4.count > 0

        case 4: return _values5.count > 0

        case 5: return _values6.count > 0

        case 6: return _values7.count > 0

        case 7: return _values8.count > 0

                if _values[atIndex].count == 1 {

                        if _values[i].count > 0 {

            resizeTo(max(_storage.count, 1) * _resizeFactor)

            resizeTo(_storage.count / _resizeFactor)

                _queue.enqueue(action)

        queue.value.enqueue(scheduledItem)

                _queue.enqueue(value)

            self._queue.enqueue(event)

        _queue.enqueue(value)

            _elements.enqueue(value)

        let observer1 = ZipObserver(lock: _lock, parent: self, index: 0, setNextValue: { self._values1.enqueue($0) }, this: subscription1)

        let observer2 = ZipObserver(lock: _lock, parent: self, index: 1, setNextValue: { self._values2.enqueue($0) }, this: subscription2)

        let observer1 = ZipObserver(lock: _lock, parent: self, index: 0, setNextValue: { self._values1.enqueue($0) }, this: subscription1)

        let observer2 = ZipObserver(lock: _lock, parent: self, index: 1, setNextValue: { self._values2.enqueue($0) }, this: subscription2)

        let observer3 = ZipObserver(lock: _lock, parent: self, index: 2, setNextValue: { self._values3.enqueue($0) }, this: subscription3)

        let observer1 = ZipObserver(lock: _lock, parent: self, index: 0, setNextValue: { self._values1.enqueue($0) }, this: subscription1)

        let observer2 = ZipObserver(lock: _lock, parent: self, index: 1, setNextValue: { self._values2.enqueue($0) }, this: subscription2)

        let observer3 = ZipObserver(lock: _lock, parent: self, index: 2, setNextValue: { self._values3.enqueue($0) }, this: subscription3)

        let observer4 = ZipObserver(lock: _lock, parent: self, index: 3, setNextValue: { self._values4.enqueue($0) }, this: subscription4)

        let observer1 = ZipObserver(lock: _lock, parent: self, index: 0, setNextValue: { self._values1.enqueue($0) }, this: subscription1)

        let observer2 = ZipObserver(lock: _lock, parent: self, index: 1, setNextValue: { self._values2.enqueue($0) }, this: subscription2)

        let observer3 = ZipObserver(lock: _lock, parent: self, index: 2, setNextValue: { self._values3.enqueue($0) }, this: subscription3)

        let observer4 = ZipObserver(lock: _lock, parent: self, index: 3, setNextValue: { self._values4.enqueue($0) }, this: subscription4)

        let observer5 = ZipObserver(lock: _lock, parent: self, index: 4, setNextValue: { self._values5.enqueue($0) }, this: subscription5)

        let observer1 = ZipObserver(lock: _lock, parent: self, index: 0, setNextValue: { self._values1.enqueue($0) }, this: subscription1)

        let observer2 = ZipObserver(lock: _lock, parent: self, index: 1, setNextValue: { self._values2.enqueue($0) }, this: subscription2)

        let observer3 = ZipObserver(lock: _lock, parent: self, index: 2, setNextValue: { self._values3.enqueue($0) }, this: subscription3)

        let observer4 = ZipObserver(lock: _lock, parent: self, index: 3, setNextValue: { self._values4.enqueue($0) }, this: subscription4)

        let observer5 = ZipObserver(lock: _lock, parent: self, index: 4, setNextValue: { self._values5.enqueue($0) }, this: subscription5)

        let observer6 = ZipObserver(lock: _lock, parent: self, index: 5, setNextValue: { self._values6.enqueue($0) }, this: subscription6)

        let observer1 = ZipObserver(lock: _lock, parent: self, index: 0, setNextValue: { self._values1.enqueue($0) }, this: subscription1)

        let observer2 = ZipObserver(lock: _lock, parent: self, index: 1, setNextValue: { self._values2.enqueue($0) }, this: subscription2)

        let observer3 = ZipObserver(lock: _lock, parent: self, index: 2, setNextValue: { self._values3.enqueue($0) }, this: subscription3)

        let observer4 = ZipObserver(lock: _lock, parent: self, index: 3, setNextValue: { self._values4.enqueue($0) }, this: subscription4)

        let observer5 = ZipObserver(lock: _lock, parent: self, index: 4, setNextValue: { self._values5.enqueue($0) }, this: subscription5)

        let observer6 = ZipObserver(lock: _lock, parent: self, index: 5, setNextValue: { self._values6.enqueue($0) }, this: subscription6)

        let observer7 = ZipObserver(lock: _lock, parent: self, index: 6, setNextValue: { self._values7.enqueue($0) }, this: subscription7)

        let observer1 = ZipObserver(lock: _lock, parent: self, index: 0, setNextValue: { self._values1.enqueue($0) }, this: subscription1)

        let observer2 = ZipObserver(lock: _lock, parent: self, index: 1, setNextValue: { self._values2.enqueue($0) }, this: subscription2)

        let observer3 = ZipObserver(lock: _lock, parent: self, index: 2, setNextValue: { self._values3.enqueue($0) }, this: subscription3)

        let observer4 = ZipObserver(lock: _lock, parent: self, index: 3, setNextValue: { self._values4.enqueue($0) }, this: subscription4)

        let observer5 = ZipObserver(lock: _lock, parent: self, index: 4, setNextValue: { self._values5.enqueue($0) }, this: subscription5)

        let observer6 = ZipObserver(lock: _lock, parent: self, index: 5, setNextValue: { self._values6.enqueue($0) }, this: subscription6)

        let observer7 = ZipObserver(lock: _lock, parent: self, index: 6, setNextValue: { self._values7.enqueue($0) }, this: subscription7)

        let observer8 = ZipObserver(lock: _lock, parent: self, index: 7, setNextValue: { self._values8.enqueue($0) }, this: subscription8)

                _values[atIndex].enqueue(element)

        let value = dequeueElementOnly()

                return _queue.dequeue()

            while let latest = queue.value.dequeue() {

            if let next = _parent._queue.dequeue() {

                return (self._queue.dequeue(), self._observer)

            _queue.dequeue()

                _elements.dequeue()

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

        return try _parent._resultSelector(_values1.dequeue()!, _values2.dequeue()!, _values3.dequeue()!, _values4.dequeue()!, _values5.dequeue()!, _values6.dequeue()!, _values7.dequeue()!, _values8.dequeue()!)

                        arguments.append(_values[i].dequeue()!)