0001    //
0002    //  ToArray.swift
0003    //  Rx
0004    //
0005    //  Created by Junior B. on 20/10/15.
0006    //  Copyright © 2015 Krunoslav Zaher. All rights reserved.
0007    //
0008    
0009    import Foundation
0010    
0011    class ToArraySink
ToArray.swift:46
        let sink = ToArraySink(parent: self, observer: observer)
<SourceType
ToArray.swift:12
    typealias Parent = ToArray<SourceType>
ToArray.swift:15
    var _list = Array<SourceType>()
ToArray.swift:23
    func on(event: Event<SourceType>) {
, O
ToArray.swift:11
class ToArraySink<SourceType, O: ObserverType where O.E == [SourceType]> : Sink<O>, ObserverType {
ToArray.swift:17
    init(parent: Parent, observer: O) {
: ObserverType where O.E == [SourceType]> : Sink<O>, ObserverType {
0012        typealias Parent
ToArray.swift:14
    let _parent: Parent
ToArray.swift:17
    init(parent: Parent, observer: O) {
 = ToArray<SourceType>
0013        
0014        let _parent
ToArray.swift:18
        _parent = parent
: Parent
0015        var _list
ToArray.swift:26
            self._list.append(value)
ToArray.swift:31
            forwardOn(.Next(_list))
 = Array<SourceType>()
0016        
0017        init
ToArray.swift:46
        let sink = ToArraySink(parent: self, observer: observer)
(parent: Parent, observer: O) {
0018            _parent = parent
0019            
0020            super.init(observer: observer)
0021        }
0022        
0023        func on(event: Event<SourceType>) {
0024            switch event {
0025            case .Next(let value):
0026                self._list.append(value)
0027            case .Error(let e):
0028                forwardOn(.Error(e))
0029                self.dispose()
0030            case .Completed:
0031                forwardOn(.Next(_list))
0032                forwardOn(.Completed)
0033                self.dispose()
0034            }
0035        }
0036    }
0037    
0038    class ToArray
Observable+Aggregate.swift:62
            return ToArray(source: self.asObservable())
ToArray.swift:12
    typealias Parent = ToArray<SourceType>
<SourceType
ToArray.swift:38
class ToArray<SourceType> : Producer<[SourceType]> {
ToArray.swift:39
    let _source: Observable<SourceType>
ToArray.swift:41
    init(source: Observable<SourceType>) {
ToArray.swift:45
    override func run<O: ObserverType where O.E == [SourceType]>(observer: O) -> Disposable {
> : Producer<[SourceType]> {
0039        let _source
ToArray.swift:42
        _source = source
ToArray.swift:47
        sink.disposable = _source.subscribe(sink)
: Observable<SourceType>
0040    
0041        init
Observable+Aggregate.swift:62
            return ToArray(source: self.asObservable())
(source: Observable<SourceType>) {
0042            _source = source
0043        }
0044        
0045        override func run<O: ObserverType where O.E == [SourceType]>(observer: O) -> Disposable {
0046            let sink = ToArraySink(parent: self, observer: observer)
0047            sink.disposable = _source.subscribe(sink)
0048            return sink
0049        }
0050    }