0001    //
0002    //  Event.swift
0003    //  Rx
0004    //
0005    //  Created by Krunoslav Zaher on 2/8/15.
0006    //  Copyright © 2015 Krunoslav Zaher. All rights reserved.
0007    //
0008    
0009    import Foundation
0010    
0011    
0012    /**
0013    Represents sequence event
0014    
0015    Sequence grammar:
0016    Next\* (Error | Completed)
0017    */
0018    public enum Event
AddRef.swift:18
    func on(event: Event<Element>) {
AddRef.swift:30
    typealias EventHandler = Event<Element> throws -> Void
Amb.swift:21
    typealias Sink = (This, Event<Element>) -> Void
Amb.swift:37
    func on(event: Event<Element>) {
Amb.swift:71
        let forwardEvent = { (o: AmbObserverType, event: Event<ElementType>) -> Void in
Amb.swift:75
        let decide = { (o: AmbObserverType, event: Event<ElementType>, me: AmbState, otherSubscription: Disposable) in
AnonymousObservable.swift:22
    func on(event: Event<E>) {
AnonymousObserver.swift:14
    typealias EventHandler = Event<Element> -> Void
AnonymousObserver.swift:25
    override func onCore(event: Event<Element>) {
AnyObserver.swift:25
    public typealias EventHandler = (Event<Element>) -> Void
AnyObserver.swift:52
    public func on(event: Event<Element>) {
Bag.swift:269
    public func on(event: Event<T.E>) {
BehaviorSubject.swift:31
    private var _stoppedEvent: Event<Element>?
BehaviorSubject.swift:75
    public func on(event: Event<E>) {
BehaviorSubject.swift:80
    func _synchronized_on(event: Event<E>) {
Buffer.swift:70
    func on(event: Event<E>) {
Buffer.swift:74
    func _synchronized_on(event: Event<E>) {
Catch.swift:23
    func on(event: Event<E>) {
Catch.swift:55
    func on(event: Event<E>) {
Catch.swift:110
    func on(event: Event<Element>) {
CombineLatest+CollectionType.swift:41
    func on(event: Event<SourceElement>, atIndex: Int) {
CombineLatest.swift:117
    func on(event: Event<Element>) {
CombineLatest.swift:121
    func _synchronized_on(event: Event<Element>) {
Concat.swift:21
    func on(event: Event<Element>){
Debug.swift:33
    func on(event: Event<Element>) {
Deferred.swift:33
    func on(event: Event<E>) {
DelaySubscription.swift:24
    func on(event: Event<E>) {
DistinctUntilChanged.swift:22
    func on(event: Event<E>) {
Do.swift:22
    func on(event: Event<Element>) {
Do.swift:38
    typealias EventHandler = Event<Element> throws -> Void
ElementAt.swift:25
    func on(event: Event<SourceType>) {
Event.swift:35
extension Event {
Event.swift:53
extension Event {
Filter.swift:24
    func on(event: Event<Element>) {
Map.swift:24
    func on(event: Event<SourceType>) {
Map.swift:61
    func on(event: Event<SourceType>) {
Merge.swift:33
    func on(event: Event<E>) {
Merge.swift:37
    func _synchronized_on(event: Event<E>) {
Merge.swift:109
    func on(event: Event<E>) {
Merge.swift:113
    func _synchronized_on(event: Event<E>) {
Merge.swift:244
    func on(event: Event<E>) {
Merge.swift:299
    func on(event: Event<SourceType>) {
Multicast.swift:42
    func on(event: Event<ResultType>) {
Observable+Extensions.swift:19
    public func subscribe(on: (event: Event<E>) -> Void)
Observable+Single.swift:87
    public func doOn(eventHandler: (Event<E>) throws -> Void)
ObserveOn.swift:54
    var _queue = Queue<Event<E>>(capacity: 10)
ObserveOn.swift:64
    override func onCore(event: Event<E>) {
ObserveOn.swift:83
        let (nextEvent, observer) = self._lock.calculateLocked { () -> (Event<E>?, O?) in
ObserveOnSerialDispatchQueue.swift:26
    var cachedScheduleLambda: ((ObserveOnSerialDispatchQueueSink<O>, Event<E>) -> Disposable)!
ObserveOnSerialDispatchQueue.swift:44
    override func onCore(event: Event<E>) {
ObserverBase.swift:16
    func on(event: Event<E>) {
ObserverBase.swift:32
    func onCore(event: Event<E>) {
ObserverType.swift:25
    func on(event: Event<E>)
PublishSubject.swift:32
    private var _stoppedEvent = nil as Event<Element>?
PublishSubject.swift:55
    public func on(event: Event<Element>) {
PublishSubject.swift:60
    func _synchronized_on(event: Event<E>) {
Reduce.swift:25
    func on(event: Event<SourceType>) {
RefCount.swift:55
    func on(event: Event<Element>) {
ReplaySubject.swift:34
    public func on(event: Event<E>) {
ReplaySubject.swift:84
    private var _stoppedEvent = nil as Event<Element>?
ReplaySubject.swift:99
    override func on(event: Event<Element>) {
ReplaySubject.swift:104
    func _synchronized_on(event: Event<E>) {
RetryWhen.swift:23
    func on(event: Event<E>) {
RetryWhen.swift:51
    func on(event: Event<E>) {
Sample.swift:29
    func on(event: Event<E>) {
Sample.swift:33
    func _synchronized_on(event: Event<E>) {
Sample.swift:94
    func on(event: Event<Element>) {
Sample.swift:98
    func _synchronized_on(event: Event<Element>) {
Scan.swift:24
    func on(event: Event<ElementType>) {
ShareReplay1.swift:26
    private var _stopEvent = nil as Event<Element>?
ShareReplay1.swift:79
    func on(event: Event<E>) {
ShareReplay1.swift:84
    func _synchronized_on(event: Event<E>) {
ShareReplay1WhileConnected.swift:73
    func on(event: Event<E>) {
ShareReplay1WhileConnected.swift:78
    func _synchronized_on(event: Event<E>) {
SingleAsync.swift:23
    func on(event: Event<E>) {
Sink.swift:21
    final func forwardOn(event: Event<O.E>) {
Sink.swift:48
    func on(event: Event<E>) {
Skip.swift:27
    func on(event: Event<Element>) {
Skip.swift:81
    func on(event: Event<Element>) {
SkipUntil.swift:33
    func on(event: Event<E>) {
SkipUntil.swift:37
    func _synchronized_on(event: Event<E>) {
SkipUntil.swift:78
    func on(event: Event<E>) {
SkipUntil.swift:82
    func _synchronized_on(event: Event<E>) {
SkipWhile.swift:22
    func on(event: Event<Element>) {
SkipWhile.swift:59
    func on(event: Event<Element>) {
SubscribeOn.swift:22
    func on(event: Event<Element>) {
Switch.swift:38
    func on(event: Event<E>) {
Switch.swift:46
    func _synchronized_on(event: Event<E>) {
Switch.swift:103
    func on(event: Event<E>) {
Switch.swift:107
    func _synchronized_on(event: Event<E>) {
SynchronizedOnType.swift:12
    func _synchronized_on(event: Event<E>)
SynchronizedOnType.swift:16
    func synchronizedOn(event: Event<E>) {
Take.swift:27
    func on(event: Event<E>) {
Take.swift:90
    func on(event: Event<E>) {
Take.swift:94
    func _synchronized_on(event: Event<E>) {
TakeLast.swift:26
    func on(event: Event<E>) {
TakeUntil.swift:33
    func on(event: Event<E>) {
TakeUntil.swift:37
    func _synchronized_on(event: Event<E>) {
TakeUntil.swift:78
    func on(event: Event<E>) {
TakeUntil.swift:82
    func _synchronized_on(event: Event<E>) {
TakeWhile.swift:26
    func on(event: Event<Element>) {
TakeWhile.swift:71
    func on(event: Event<Element>) {
Throttle.swift:41
    func on(event: Event<Element>) {
Throttle.swift:45
    func _synchronized_on(event: Event<Element>) {
Timeout.swift:41
    func on(event: Event<E>) {
ToArray.swift:23
    func on(event: Event<SourceType>) {
Using.swift:43
    func on(event: Event<E>) {
Window.swift:56
    func on(event: Event<E>) {
Window.swift:60
    func _synchronized_on(event: Event<E>) {
WithLatestFrom.swift:41
    func on(event: Event<E>) {
WithLatestFrom.swift:45
    func _synchronized_on(event: Event<E>) {
WithLatestFrom.swift:89
    func on(event: Event<E>) {
WithLatestFrom.swift:93
    func _synchronized_on(event: Event<E>) {
Zip+CollectionType.swift:41
    func on(event: Event<SourceElement>, atIndex: Int) {
Zip.swift:129
    func on(event: Event<E>) {
Zip.swift:133
    func _synchronized_on(event: Event<E>) {
<Element
Event.swift:22
    case Next(Element)
> : CustomDebugStringConvertible {
0019        /**
0020        Next element is produced
0021        */
0022        case Next
AddRef.swift:20
        case .Next(_):
AnonymousObservable.swift:24
        case .Next:
BehaviorSubject.swift:86
        case .Next(let value):
BehaviorSubject.swift:118
        observer.on(.Next(_value))
Buffer.swift:65
        forwardOn(.Next(buffer))
Buffer.swift:76
        case .Next(let element):
Buffer.swift:88
            forwardOn(.Next(_buffer))
Catch.swift:27
        case .Next:
Catch.swift:57
        case .Next:
Catch.swift:112
        case .Next:
CombineLatest+CollectionType.swift:44
            case .Next(let element):
CombineLatest+CollectionType.swift:62
                    forwardOn(.Next(result))
CombineLatest.swift:51
                forwardOn(.Next(result))
CombineLatest.swift:123
        case .Next(let value):
Concat.swift:23
        case .Next:
Deferred.swift:37
        case .Next:
DistinctUntilChanged.swift:24
        case .Next(let value):
ElementAt.swift:27
        case .Next(_):
Event.swift:42
            case .Next(let value):
Event.swift:60
            case .Next: return false
Event.swift:71
            if case .Next(let value) = self {
Filter.swift:26
            case .Next(let value):
Filter.swift:30
                        forwardOn(.Next(value))
Generate.swift:33
                    self.forwardOn(.Next(result))
Just.swift:24
            self.forwardOn(.Next(element))
Just.swift:57
        observer.on(.Next(_element))
Map.swift:26
        case .Next(let element):
Map.swift:29
                forwardOn(.Next(mappedElement))
Map.swift:63
        case .Next(let element):
Map.swift:66
                forwardOn(.Next(mappedElement))
Merge.swift:39
        case .Next:
Merge.swift:115
        case .Next(let value):
Merge.swift:246
        case .Next(let value):
Merge.swift:248
                _parent.forwardOn(.Next(value))
Merge.swift:301
        case .Next(let element):
Multicast.swift:45
            case .Next: break
Observable+Extensions.swift:52
            case .Next(let value):
Observable+Extensions.swift:78
            if case .Next(let value) = e {
Observable+Single.swift:107
            case .Next(let element):
ObserverBase.swift:18
        case .Next:
ObserverType.swift:39
        on(.Next(element))
PublishSubject.swift:62
        case .Next(_):
Range.swift:50
                self.forwardOn(.Next(self._parent._start + i))
Reduce.swift:27
        case .Next(let value):
Reduce.swift:41
                forwardOn(.Next(result))
RefCount.swift:57
        case .Next:
Repeat.swift:40
            self.forwardOn(.Next(e))
ReplaySubject.swift:114
        case .Next(let value):
ReplaySubject.swift:198
            observer.on(.Next(value))
ReplaySubject.swift:221
            observer.on(.Next(item))
RetryWhen.swift:25
        case .Next:
RetryWhen.swift:53
        case .Next:
RetryWhen.swift:64
                _parent._errorSubject.on(.Next(failedWith))
Sample.swift:35
        case .Next:
Sample.swift:41
                _parent.forwardOn(.Next(element))
Sample.swift:54
                _parent.forwardOn(.Next(element))
Sample.swift:100
        case .Next(let element):
Scan.swift:26
        case .Next(let element):
Scan.swift:29
                forwardOn(.Next(_accumulate))
Sequence.swift:24
                self.forwardOn(.Next(state.1[state.0]))
Sequence.swift:47
                observer.on(.Next(element))
ShareReplay1.swift:40
            observer.on(.Next(element))
ShareReplay1.swift:90
        case .Next(let element):
ShareReplay1WhileConnected.swift:38
            observer.on(.Next(element))
ShareReplay1WhileConnected.swift:80
        case .Next(let element):
SingleAsync.swift:25
        case .Next(let value):
SingleAsync.swift:39
                forwardOn(.Next(value))
Sink.swift:50
        case .Next:
Skip.swift:29
        case .Next(let value):
Skip.swift:32
                forwardOn(.Next(value))
Skip.swift:83
        case .Next(let value):
Skip.swift:85
                forwardOn(.Next(value))
SkipUntil.swift:39
        case .Next:
SkipUntil.swift:84
        case .Next:
SkipWhile.swift:24
        case .Next(let value):
SkipWhile.swift:36
                forwardOn(.Next(value))
SkipWhile.swift:61
        case .Next(let value):
SkipWhile.swift:74
                forwardOn(.Next(value))
StartWith.swift:23
            observer.on(.Next(e))
Switch.swift:48
        case .Next(let element):
Switch.swift:109
        case .Next: break
Switch.swift:119
        case .Next:
Take.swift:29
        case .Next(let value):
Take.swift:34
                forwardOn(.Next(value))
Take.swift:96
        case .Next(let value):
Take.swift:97
            forwardOn(.Next(value))
TakeLast.swift:28
        case .Next(let value):
TakeLast.swift:38
                forwardOn(.Next(e))
TakeUntil.swift:39
        case .Next:
TakeUntil.swift:84
        case .Next:
TakeWhile.swift:28
        case .Next(let value):
TakeWhile.swift:42
                forwardOn(.Next(value))
TakeWhile.swift:73
        case .Next(let value):
TakeWhile.swift:88
                forwardOn(.Next(value))
Throttle.swift:47
        case .Next(let element):
Throttle.swift:66
                forwardOn(.Next(value))
Throttle.swift:79
                forwardOn(.Next(value))
Timeout.swift:43
        case .Next:
Timer.swift:23
            self.forwardOn(.Next(state))
Timer.swift:41
            self.forwardOn(.Next(0))
ToArray.swift:25
        case .Next(let value):
ToArray.swift:31
            forwardOn(.Next(_list))
Using.swift:45
        case let .Next(value):
Using.swift:46
            forwardOn(.Next(value))
Variable.swift:45
            _subject.on(.Next(newValue))
Window.swift:42
        forwardOn(.Next(AddRef(source: _subject, refCount: _refCountDisposable).asObservable()))
Window.swift:53
        forwardOn(.Next(AddRef(source: _subject, refCount: _refCountDisposable).asObservable()))
Window.swift:65
        case .Next(let element):
Window.swift:66
            _subject.on(.Next(element))
WithLatestFrom.swift:47
        case let .Next(value):
WithLatestFrom.swift:52
                forwardOn(.Next(res))
WithLatestFrom.swift:95
        case let .Next(value):
Zip+CollectionType.swift:44
            case .Next(let element):
Zip+CollectionType.swift:75
                    self.forwardOn(.Next(result))
Zip.swift:56
                self.forwardOn(.Next(result))
Zip.swift:136
            case .Next(_):
Zip.swift:147
            case .Next(let value):
(Element)
0023        
0024        /**
0025        Sequence terminates with error
0026        */
0027        case Error
AddRef.swift:22
        case .Completed, .Error(_):
AnonymousObservable.swift:29
        case .Error, .Completed:
BehaviorSubject.swift:88
        case .Error, .Completed:
BehaviorSubject.swift:108
            observer.on(.Error(RxError.Disposed(object: self)))
Buffer.swift:83
        case .Error(let error):
Buffer.swift:85
            forwardOn(.Error(error))
Catch.swift:29
        case .Error, .Completed:
Catch.swift:62
        case .Error(let error):
Catch.swift:71
                forwardOn(.Error(e))
Catch.swift:114
        case .Error(let error):
Catch.swift:129
            forwardOn(.Error(lastError))
CombineLatest+CollectionType.swift:65
                    forwardOn(.Error(error))
CombineLatest+CollectionType.swift:69
            case .Error(let error):
CombineLatest+CollectionType.swift:70
                forwardOn(.Error(error))
CombineLatest.swift:54
                forwardOn(.Error(e))
CombineLatest.swift:76
        forwardOn(.Error(error))
CombineLatest.swift:126
        case .Error(let error):
Concat.swift:25
        case .Error:
Deferred.swift:27
            forwardOn(.Error(e))
Deferred.swift:39
        case .Error:
DistinctUntilChanged.swift:41
                forwardOn(.Error(error))
DistinctUntilChanged.swift:44
        case .Error, .Completed:
Do.swift:31
            forwardOn(.Error(error))
ElementAt.swift:38
                forwardOn(.Error(e))
ElementAt.swift:43
        case .Error(let e):
ElementAt.swift:44
            forwardOn(.Error(e))
ElementAt.swift:48
                forwardOn(.Error(RxError.ArgumentOutOfRange))
Error.swift:19
        observer.on(.Error(_error))
Event.swift:44
            case .Error(let error):
Event.swift:61
            case .Error, .Completed: return true
Event.swift:83
            if case .Error(let error) = self {
Filter.swift:34
                    forwardOn(.Error(e))
Filter.swift:37
            case .Completed, .Error:
Generate.swift:43
                self.forwardOn(.Error(error))
Map.swift:32
                forwardOn(.Error(e))
Map.swift:35
        case .Error(let error):
Map.swift:36
            forwardOn(.Error(error))
Map.swift:69
                forwardOn(.Error(e))
Map.swift:72
        case .Error(let error):
Map.swift:73
            forwardOn(.Error(error))
Merge.swift:41
        case .Error:
Merge.swift:129
        case .Error(let error):
Merge.swift:130
            forwardOn(.Error(error))
Merge.swift:250
        case .Error(let error):
Merge.swift:252
                _parent.forwardOn(.Error(error))
Merge.swift:310
                forwardOn(.Error(e))
Merge.swift:313
        case .Error(let error):
Merge.swift:315
                forwardOn(.Error(error))
Multicast.swift:36
            forwardOn(.Error(e))
Multicast.swift:46
            case .Error, .Completed:
Observable+Extensions.swift:54
            case .Error(let e):
Observable+Extensions.swift:95
            if case .Error(let error) = e {
Observable+Single.swift:109
            case .Error(let e):
ObserverBase.swift:22
        case .Error, .Completed:
ObserverType.swift:54
        on(.Error(error))
PublishSubject.swift:68
        case .Completed, .Error:
PublishSubject.swift:96
            observer.on(.Error(RxError.Disposed(object: self)))
Reduce.swift:32
                forwardOn(.Error(e))
Reduce.swift:35
        case .Error(let e):
Reduce.swift:36
            forwardOn(.Error(e))
Reduce.swift:46
                forwardOn(.Error(e))
RefCount.swift:59
        case .Error, .Completed:
ReplaySubject.swift:118
        case .Error, .Completed:
ReplaySubject.swift:133
            observer.on(.Error(RxError.Disposed(object: self)))
RetryWhen.swift:28
        case .Error(let e):
RetryWhen.swift:29
            _parent._parent.forwardOn(.Error(e))
RetryWhen.swift:55
        case .Error(let error):
RetryWhen.swift:67
                _parent.forwardOn(.Error(error))
RetryWhen.swift:104
            forwardOn(.Error(lastError))
Sample.swift:48
        case .Error(let e):
Sample.swift:49
            _parent.forwardOn(.Error(e))
Sample.swift:102
        case .Error:
Scan.swift:32
                forwardOn(.Error(error))
Scan.swift:35
        case .Error(let error):
Scan.swift:36
            forwardOn(.Error(error))
ShareReplay1.swift:92
        case .Error, .Completed:
ShareReplay1WhileConnected.swift:83
        case .Error, .Completed:
SingleAsync.swift:33
                forwardOn(.Error(error as ErrorType))
SingleAsync.swift:42
                forwardOn(.Error(RxError.MoreThanOneElement))
SingleAsync.swift:46
        case .Error:
SingleAsync.swift:51
                forwardOn(.Error(RxError.NoElements))
Sink.swift:52
        case .Error, .Completed:
Skip.swift:37
        case .Error:
Skip.swift:87
        case .Error:
SkipUntil.swift:42
        case .Error(let e):
SkipUntil.swift:43
            _parent.forwardOn(.Error(e))
SkipUntil.swift:88
        case .Error:
SkipWhile.swift:29
                    forwardOn(.Error(e))
SkipWhile.swift:38
        case .Error, .Completed:
SkipWhile.swift:67
                    forwardOn(.Error(e))
SkipWhile.swift:76
        case .Error, .Completed:
Switch.swift:63
                forwardOn(.Error(error))
Switch.swift:66
        case .Error(let error):
Switch.swift:67
            forwardOn(.Error(error))
Switch.swift:110
        case .Error, .Completed:
Switch.swift:121
        case .Error:
Take.swift:41
        case .Error:
Take.swift:98
        case .Error:
TakeLast.swift:33
        case .Error:
TakeUntil.swift:42
        case .Error(let e):
TakeUntil.swift:43
            _parent.forwardOn(.Error(e))
TakeUntil.swift:86
        case .Error:
TakeWhile.swift:36
                forwardOn(.Error(e))
TakeWhile.swift:47
        case .Error, .Completed:
TakeWhile.swift:82
                forwardOn(.Error(e))
TakeWhile.swift:93
        case .Error, .Completed:
Throttle.swift:59
        case .Error:
Timeout.swift:57
        case .Error, .Completed:
ToArray.swift:27
        case .Error(let e):
ToArray.swift:28
            forwardOn(.Error(e))
Using.swift:47
        case let .Error(error):
Using.swift:48
            forwardOn(.Error(error))
Window.swift:71
                _subject.on(.Error(e as ErrorType))
Window.swift:83
        case .Error(let error):
Window.swift:84
            _subject.on(.Error(error))
Window.swift:85
            forwardOn(.Error(error))
WithLatestFrom.swift:54
                forwardOn(.Error(e))
WithLatestFrom.swift:60
        case let .Error(error):
WithLatestFrom.swift:61
            forwardOn(.Error(error))
WithLatestFrom.swift:99
        case let .Error(error):
WithLatestFrom.swift:100
            _parent.forwardOn(.Error(error))
Zip+CollectionType.swift:78
                    self.forwardOn(.Error(error))
Zip+CollectionType.swift:82
            case .Error(let error):
Zip+CollectionType.swift:83
                self.forwardOn(.Error(error))
Zip.swift:59
                self.forwardOn(.Error(e))
Zip.swift:82
        forwardOn(.Error(error))
Zip.swift:138
            case .Error(_):
Zip.swift:150
            case .Error(let error):
(ErrorType)
0028        
0029        /**
0030        Sequence completes sucessfully
0031        */
0032        case Completed
AddRef.swift:22
        case .Completed, .Error(_):
AnonymousObservable.swift:29
        case .Error, .Completed:
BehaviorSubject.swift:88
        case .Error, .Completed:
Buffer.swift:87
        case .Completed:
Buffer.swift:89
            forwardOn(.Completed)
Catch.swift:29
        case .Error, .Completed:
Catch.swift:59
        case .Completed:
Catch.swift:117
        case .Completed:
Catch.swift:132
            forwardOn(.Completed)
CombineLatest+CollectionType.swift:54
                        forwardOn(.Completed)
CombineLatest+CollectionType.swift:72
            case .Completed:
CombineLatest+CollectionType.swift:81
                    forwardOn(.Completed)
CombineLatest.swift:69
                forwardOn(.Completed)
CombineLatest.swift:89
            forwardOn(.Completed)
CombineLatest.swift:129
        case .Completed:
Concat.swift:28
        case .Completed:
Deferred.swift:41
        case .Completed:
DistinctUntilChanged.swift:44
        case .Error, .Completed:
ElementAt.swift:31
                forwardOn(.Completed)
ElementAt.swift:46
        case .Completed:
ElementAt.swift:50
                forwardOn(.Completed)
Empty.swift:13
        observer.on(.Completed)
Event.swift:46
            case .Completed:
Event.swift:61
            case .Error, .Completed: return true
Filter.swift:37
            case .Completed, .Error:
Generate.swift:38
                    self.forwardOn(.Completed)
Just.swift:26
                self.forwardOn(.Completed)
Just.swift:58
        observer.on(.Completed)
Map.swift:38
        case .Completed:
Map.swift:39
            forwardOn(.Completed)
Map.swift:75
        case .Completed:
Map.swift:76
            forwardOn(.Completed)
Merge.swift:44
        case .Completed:
Merge.swift:53
                    _parent.forwardOn(.Completed)
Merge.swift:132
        case .Completed:
Merge.swift:134
                forwardOn(.Completed)
Merge.swift:255
        case .Completed:
Merge.swift:264
                    _parent.forwardOn(.Completed)
Merge.swift:318
        case .Completed:
Merge.swift:322
                    forwardOn(.Completed)
Multicast.swift:46
            case .Error, .Completed:
Observable+Extensions.swift:57
            case .Completed:
Observable+Extensions.swift:112
            if case .Completed = e {
Observable+Single.swift:111
            case .Completed:
ObserverBase.swift:22
        case .Error, .Completed:
ObserverType.swift:46
        on(.Completed)
PublishSubject.swift:68
        case .Completed, .Error:
Range.swift:54
                self.forwardOn(.Completed)
Reduce.swift:38
        case .Completed:
Reduce.swift:42
                forwardOn(.Completed)
RefCount.swift:59
        case .Error, .Completed:
ReplaySubject.swift:118
        case .Error, .Completed:
RetryWhen.swift:31
        case .Completed:
RetryWhen.swift:32
            _parent._parent.forwardOn(.Completed)
RetryWhen.swift:70
        case .Completed:
RetryWhen.swift:108
            forwardOn(.Completed)
Sample.swift:45
                _parent.forwardOn(.Completed)
Sample.swift:51
        case .Completed:
Sample.swift:57
                _parent.forwardOn(.Completed)
Sample.swift:105
        case .Completed:
Scan.swift:38
        case .Completed:
Scan.swift:39
            forwardOn(.Completed)
Sequence.swift:28
                self.forwardOn(.Completed)
Sequence.swift:50
            observer.on(.Completed)
ShareReplay1.swift:92
        case .Error, .Completed:
ShareReplay1WhileConnected.swift:83
        case .Error, .Completed:
SingleAsync.swift:49
        case .Completed:
SingleAsync.swift:53
                forwardOn(.Completed)
Sink.swift:52
        case .Error, .Completed:
Skip.swift:40
        case .Completed:
Skip.swift:90
        case .Completed:
SkipUntil.swift:45
        case .Completed:
SkipUntil.swift:91
        case .Completed:
SkipWhile.swift:38
        case .Error, .Completed:
SkipWhile.swift:76
        case .Error, .Completed:
Switch.swift:69
        case .Completed:
Switch.swift:75
                forwardOn(.Completed)
Switch.swift:110
        case .Error, .Completed:
Switch.swift:124
        case .Completed:
TailRecursiveSink.swift:62
        forwardOn(.Completed)
Take.swift:37
                    forwardOn(.Completed)
Take.swift:44
        case .Completed:
Take.swift:101
        case .Completed:
Take.swift:110
        forwardOn(.Completed)
TakeLast.swift:36
        case .Completed:
TakeLast.swift:40
            forwardOn(.Completed)
TakeUntil.swift:40
            _parent.forwardOn(.Completed)
TakeUntil.swift:45
        case .Completed:
TakeUntil.swift:89
        case .Completed:
TakeWhile.swift:44
                forwardOn(.Completed)
TakeWhile.swift:47
        case .Error, .Completed:
TakeWhile.swift:90
                forwardOn(.Completed)
TakeWhile.swift:93
        case .Error, .Completed:
Throttle.swift:63
        case .Completed:
Throttle.swift:68
            forwardOn(.Completed)
Timeout.swift:57
        case .Error, .Completed:
Timer.swift:42
            self.forwardOn(.Completed)
ToArray.swift:30
        case .Completed:
ToArray.swift:32
            forwardOn(.Completed)
Using.swift:50
        case .Completed:
Using.swift:51
            forwardOn(.Completed)
Variable.swift:67
        _subject.on(.Completed)
Window.swift:50
        _subject.on(.Completed)
Window.swift:87
        case .Completed:
Window.swift:88
            _subject.on(.Completed)
Window.swift:89
            forwardOn(.Completed)
WithLatestFrom.swift:57
        case .Completed:
WithLatestFrom.swift:58
            forwardOn(.Completed)
WithLatestFrom.swift:97
        case .Completed:
Zip+CollectionType.swift:54
                        self.forwardOn(.Completed)
Zip+CollectionType.swift:85
            case .Completed:
Zip+CollectionType.swift:94
                    self.forwardOn(.Completed)
Zip.swift:75
                forwardOn(.Completed)
Zip.swift:99
            forwardOn(.Completed)
Zip.swift:140
            case .Completed:
Zip.swift:152
            case .Completed:

0033    }
0034    
0035    extension Event {
0036        /**
0037        - returns: Description of event
0038        */
0039        public var debugDescription: String {
0040            get {
0041                switch self {
0042                case .Next(let value):
0043                    return "Next(\(value))"
0044                case .Error(let error):
0045                    return "Error(\(error))"
0046                case .Completed:
0047                    return "Completed"
0048                }
0049            }
0050        }
0051    }
0052    
0053    extension Event {
0054        /**
0055        - returns: Is `Completed` or `Error` event
0056        */
0057        public var isStopEvent
Amb.swift:39
        if event.isStopEvent {
Amb.swift:86
                    if event.isStopEvent {
DelaySubscription.swift:26
        if event.isStopEvent {
Do.swift:26
            if event.isStopEvent {
ObserveOn.swift:95
            if nextEvent.isStopEvent {
ObserveOnSerialDispatchQueue.swift:36
            if event.isStopEvent {
SubscribeOn.swift:25
        if event.isStopEvent {
: Bool {
0058            get {
0059                switch self {
0060                case .Next: return false
0061                case .Error, .Completed: return true
0062                }
0063            }
0064        }
0065        
0066        /**
0067        - returns: If `Next` event, returns element value.
0068        */
0069        public var element: Element? {
0070            get {
0071                if case .Next(let value) = self {
0072                    return value
0073                }
0074                return nil
0075            }
0076        }
0077        
0078        /**
0079        - returns: If `Error` event, returns error.
0080        */
0081        public var error
BehaviorSubject.swift:60
            if let error = _stoppedEvent?.error {
: ErrorType? {
0082            get {
0083                if case .Error(let error) = self {
0084                    return error
0085                }
0086                return nil
0087            }
0088        }
0089    }