0001    //
0002    //  ObserverType.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    Supports push-style iteration over an observable sequence.
0013    */
0014    public protocol ObserverType
AddRef.swift:11
class AddRefSink<O: ObserverType> : Sink<O>, ObserverType {
AddRef.swift:40
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Amb.swift:17
class AmbObserver<ElementType, O: ObserverType where O.E == ElementType> : ObserverType {
Amb.swift:117
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
AnonymousObservable.swift:11
class AnonymousObservableSink<O: ObserverType> : Sink<O>, ObserverType {
AnonymousObservable.swift:51
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
AnyObserver.swift:16
public struct AnyObserver<Element> : ObserverType {
AnyObserver.swift:43
    public init<O : ObserverType where O.E == Element>(_ observer: O) {
AnyObserver.swift:66
extension ObserverType {
BehaviorSubject.swift:19
    , ObserverType
BehaviorSubject.swift:101
    public override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
BehaviorSubject.swift:106
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Buffer.swift:25
    override func run<O : ObserverType where O.E == [Element]>(observer: O) -> Disposable {
Buffer.swift:35
    , ObserverType
Catch.swift:13
class CatchSinkProxy<O: ObserverType> : ObserverType {
Catch.swift:35
class CatchSink<O: ObserverType> : Sink<O>, ObserverType {
Catch.swift:89
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Catch.swift:100
    , ObserverType {
Catch.swift:157
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
CombineLatest+arity.swift:86
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:174
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:269
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:371
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:480
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:596
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:719
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+CollectionType.swift:120
    override func run<O : ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest.swift:96
    : ObserverType
Concat.swift:14
    , ObserverType {
Concat.swift:58
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
ConnectableObservable.swift:89
    override func subscribe<O : ObserverType where O.E == S.E>(observer: O) -> Disposable {
Debug.swift:17
class Debug_<O: ObserverType> : Sink<O>, ObserverType {
Debug.swift:72
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Deferred.swift:11
class DeferredSink<S: ObservableType, O: ObserverType where S.E == O.E> : Sink<O>, ObserverType {
Deferred.swift:56
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
DelaySubscription.swift:13
    , ObserverType {
DelaySubscription.swift:44
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
DistinctUntilChanged.swift:11
class DistinctUntilChangedSink<O: ObserverType, Key>: Sink<O>, ObserverType {
DistinctUntilChanged.swift:65
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Do.swift:11
class DoSink<O: ObserverType> : Sink<O>, ObserverType {
Do.swift:48
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
ElementAt.swift:12
class ElementAtSink<SourceType, O: ObserverType where O.E == SourceType> : Sink<O>, ObserverType {
ElementAt.swift:74
    override func run<O: ObserverType where O.E == SourceType>(observer: O) -> Disposable {
Empty.swift:12
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Error.swift:18
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Filter.swift:11
class FilterSink<O : ObserverType>: Sink<O>, ObserverType {
Filter.swift:55
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Generate.swift:66
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Just.swift:42
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Just.swift:56
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Map.swift:11
class MapSink<SourceType, O : ObserverType> : Sink<O>, ObserverType {
Map.swift:45
class MapWithIndexSink<SourceType, O : ObserverType> : Sink<O>, ObserverType {
Map.swift:94
    override func run<O: ObserverType where O.E == ResultType>(observer: O) -> Disposable {
Map.swift:129
    override func run<O: ObserverType where O.E == ResultType>(observer: O) -> Disposable {
Merge.swift:14
    : ObserverType
Merge.swift:63
    , ObserverType
Merge.swift:155
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:231
class MergeSinkIter<SourceType, S: ObservableConvertibleType, O: ObserverType where O.E == S.E> : ObserverType {
Merge.swift:275
    , ObserverType {
Merge.swift:365
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:384
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:404
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:418
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Multicast.swift:11
class MulticastSink<S: SubjectType, O: ObserverType>: Sink<O>, ObserverType {
Multicast.swift:66
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Never.swift:12
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Observable+Extensions.swift:125
    func subscribeSafe<O: ObserverType where O.E == E>(observer: O) -> Disposable {
Observable.swift:28
    public func subscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable {
ObservableType.swift:44
    func subscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable
ObserveOn.swift:24
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ObserveOnSerialDispatchQueue.swift:69
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ObserverBase.swift:11
class ObserverBase<ElementType> : Disposable, ObserverType {
ObserverType.swift:31
public extension ObserverType {
Producer.swift:16
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Producer.swift:27
    func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
PublishSubject.swift:20
    , ObserverType
PublishSubject.swift:84
    public override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
PublishSubject.swift:89
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Range.swift:30
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Reduce.swift:11
class ReduceSink<SourceType, AccumulateType, O: ObserverType> : Sink<O>, ObserverType {
Reduce.swift:69
    override func run<O: ObserverType where O.E == ResultType>(observer: O) -> Disposable {
RefCount.swift:13
    , ObserverType {
RefCount.swift:79
    override func run<O: ObserverType where O.E == CO.E>(observer: O) -> Disposable {
Repeat.swift:20
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
ReplaySubject.swift:19
    , ObserverType
ReplaySubject.swift:126
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
ReplaySubject.swift:131
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
RetryWhen.swift:12
    : ObserverType {
RetryWhen.swift:40
    , ObserverType {
RetryWhen.swift:145
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Sample.swift:12
    : ObserverType
Sample.swift:66
    , ObserverType
Sample.swift:124
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Scan.swift:11
class ScanSink<ElementType, Accumulate, O: ObserverType where O.E == Accumulate> : Sink<O>, ObserverType {
Scan.swift:59
    override func run<O : ObserverType where O.E == Accumulate>(observer: O) -> Disposable {
Sequence.swift:43
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1.swift:14
    , ObserverType
ShareReplay1.swift:33
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1.swift:38
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1WhileConnected.swift:14
    , ObserverType
ShareReplay1WhileConnected.swift:31
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1WhileConnected.swift:36
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
SingleAsync.swift:11
class SingleAsyncSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
SingleAsync.swift:71
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Sink.swift:39
class SinkForward<O: ObserverType>: ObserverType {
Skip.swift:13
class SkipCountSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
Skip.swift:57
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Skip.swift:67
class SkipTimeSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
Skip.swift:123
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SkipUntil.swift:12
    : ObserverType
SkipUntil.swift:61
    , ObserverType
SkipUntil.swift:120
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SkipWhile.swift:9
class SkipWhileSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
SkipWhile.swift:45
class SkipWhileSinkWithIndex<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
SkipWhile.swift:103
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
StartWith.swift:21
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SubscribeOn.swift:11
class SubscribeOnSink<Ob: ObservableType, O: ObserverType where Ob.E == O.E> : Sink<O>, ObserverType {
SubscribeOn.swift:55
    override func run<O : ObserverType where O.E == Ob.E>(observer: O) -> Disposable {
Switch.swift:13
    , ObserverType
Switch.swift:83
    : ObserverType
Switch.swift:170
    override func run<O : ObserverType where O.E == S.E>(observer: O) -> Disposable {
Switch.swift:188
    override func run<O : ObserverType where O.E == S.E>(observer: O) -> Disposable {
SynchronizedOnType.swift:11
protocol SynchronizedOnType : class, ObserverType, Lock {
SynchronizedSubscribeType.swift:12
    func _synchronized_subscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable
SynchronizedSubscribeType.swift:16
    func synchronizedSubscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable {
Take.swift:13
class TakeCountSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
Take.swift:64
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Take.swift:76
    , ObserverType
Take.swift:139
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
TakeLast.swift:12
class TakeLastSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
TakeLast.swift:58
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
TakeUntil.swift:12
    : ObserverType
TakeUntil.swift:61
    , ObserverType
TakeUntil.swift:115
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
TakeWhile.swift:13
    , ObserverType {
TakeWhile.swift:57
    , ObserverType {
TakeWhile.swift:121
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Throttle.swift:13
    , ObserverType
Throttle.swift:98
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Timeout.swift:11
class TimeoutSink<ElementType, O: ObserverType where O.E == ElementType>: Sink<O>, LockOwnerType, ObserverType {
Timeout.swift:115
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Timer.swift:60
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ToArray.swift:11
class ToArraySink<SourceType, O: ObserverType where O.E == [SourceType]> : Sink<O>, ObserverType {
ToArray.swift:45
    override func run<O: ObserverType where O.E == [SourceType]>(observer: O) -> Disposable {
Using.swift:11
class UsingSink<SourceType, ResourceType: Disposable, O: ObserverType where O.E == SourceType> : Sink<O>, ObserverType {
Using.swift:73
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Window.swift:13
    , ObserverType
Window.swift:147
    override func run<O : ObserverType where O.E == Observable<Element>>(observer: O) -> Disposable {
WithLatestFrom.swift:13
    , ObserverType
WithLatestFrom.swift:68
    : ObserverType
WithLatestFrom.swift:119
    override func run<O : ObserverType where O.E == ResultType>(observer: O) -> Disposable {
Zip+arity.swift:98
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:199
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:308
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:425
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:550
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:683
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:824
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+CollectionType.swift:132
    override func run<O : ObserverType where O.E == R>(observer: O) -> Disposable {
Zip.swift:106
    : ObserverType
 {
0015        /**
0016        The type of elements in sequence that observer can observe.
0017        */
0018        typealias E
AddRef.swift:12
    typealias Element = O.E
AddRef.swift:40
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Amb.swift:117
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
AnonymousObservable.swift:12
    typealias E = O.E
AnonymousObservable.swift:51
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
AnyObserver.swift:43
    public init<O : ObserverType where O.E == Element>(_ observer: O) {
AnyObserver.swift:72
    public func asObserver() -> AnyObserver<E> {
Bag.swift:269
    public func on(event: Event<T.E>) {
BehaviorSubject.swift:101
    public override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
BehaviorSubject.swift:106
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Buffer.swift:25
    override func run<O : ObserverType where O.E == [Element]>(observer: O) -> Disposable {
Catch.swift:14
    typealias E = O.E
Catch.swift:36
    typealias E = O.E
Catch.swift:89
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Catch.swift:101
    typealias Element = O.E
Catch.swift:157
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
CombineLatest+arity.swift:37
    typealias R = O.E
CombineLatest+arity.swift:86
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:118
    typealias R = O.E
CombineLatest+arity.swift:174
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:206
    typealias R = O.E
CombineLatest+arity.swift:269
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:301
    typealias R = O.E
CombineLatest+arity.swift:371
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:403
    typealias R = O.E
CombineLatest+arity.swift:480
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:512
    typealias R = O.E
CombineLatest+arity.swift:596
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:628
    typealias R = O.E
CombineLatest+arity.swift:719
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+CollectionType.swift:120
    override func run<O : ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest.swift:20
    typealias Element = O.E
Concat.swift:15
    typealias Element = O.E
Concat.swift:58
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
ConnectableObservable.swift:63
    private let _source: Observable<S.SubjectObserverType.E>
ConnectableObservable.swift:70
    init(source: Observable<S.SubjectObserverType.E>, subject: S) {
ConnectableObservable.swift:89
    override func subscribe<O : ObserverType where O.E == S.E>(observer: O) -> Disposable {
Debug.swift:18
    typealias Element = O.E
Debug.swift:72
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Deferred.swift:12
    typealias E = O.E
Deferred.swift:56
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
DelaySubscription.swift:15
    typealias E = O.E
DelaySubscription.swift:44
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
DistinctUntilChanged.swift:12
    typealias E = O.E
DistinctUntilChanged.swift:65
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Do.swift:12
    typealias Element = O.E
Do.swift:48
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
ElementAt.swift:74
    override func run<O: ObserverType where O.E == SourceType>(observer: O) -> Disposable {
Empty.swift:12
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Error.swift:18
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Filter.swift:13
    typealias Element = O.E
Filter.swift:55
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Generate.swift:12
    typealias Parent = Generate<S, O.E>
Generate.swift:66
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Just.swift:12
    typealias Parent = JustScheduled<O.E>
Just.swift:42
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Just.swift:56
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Map.swift:14
    typealias ResultType = O.E
Map.swift:48
    typealias ResultType = O.E
Map.swift:94
    override func run<O: ObserverType where O.E == ResultType>(observer: O) -> Disposable {
Map.swift:129
    override func run<O: ObserverType where O.E == ResultType>(observer: O) -> Disposable {
Merge.swift:17
    typealias E = O.E
Merge.swift:155
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:234
    typealias E = O.E
Merge.swift:276
    typealias ResultType = O.E
Merge.swift:332
    func subscribeInner(source: Observable<O.E>) {
Merge.swift:365
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:384
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:404
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:418
    override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Multicast.swift:12
    typealias Element = O.E
Multicast.swift:14
    typealias MutlicastType = Multicast<S, O.E>
Multicast.swift:56
    private let _source: Observable<S.SubjectObserverType.E>
Multicast.swift:60
    init(source: Observable<S.SubjectObserverType.E>, subjectSelector: SubjectSelectorType, selector: SelectorType) {
Multicast.swift:66
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Never.swift:12
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Observable+Binding.swift:28
    public func multicast<S: SubjectType where S.SubjectObserverType.E == E>(subject: S)
Observable+Binding.swift:47
    public func multicast<S: SubjectType, R where S.SubjectObserverType.E == E>(subjectSelector: () throws -> S, selector: (Observable<S.E>) throws -> Observable<R>)
Observable+Extensions.swift:125
    func subscribeSafe<O: ObserverType where O.E == E>(observer: O) -> Disposable {
Observable.swift:28
    public func subscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable {
ObservableType.swift:44
    func subscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable
ObserveOn.swift:24
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ObserveOn.swift:44
class ObserveOnSink<O: ObserverType> : ObserverBase<O.E> {
ObserveOn.swift:45
    typealias E = O.E
ObserveOnSerialDispatchQueue.swift:20
class ObserveOnSerialDispatchQueueSink<O: ObserverType> : ObserverBase<O.E> {
ObserveOnSerialDispatchQueue.swift:69
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ObserverType.swift:25
    func on(event: Event<E>)
ObserverType.swift:38
    final func onNext(element: E) {
Producer.swift:16
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Producer.swift:27
    func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
PublishSubject.swift:84
    public override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
PublishSubject.swift:89
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Range.swift:30
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Range.swift:38
    typealias Parent = RangeProducer<O.E>
Range.swift:48
        return _parent._scheduler.scheduleRecursive(0 as O.E) { i, recurse in
Reduce.swift:12
    typealias ResultType = O.E
Reduce.swift:69
    override func run<O: ObserverType where O.E == ResultType>(observer: O) -> Disposable {
RefCount.swift:14
    typealias Element = O.E
RefCount.swift:79
    override func run<O: ObserverType where O.E == CO.E>(observer: O) -> Disposable {
Repeat.swift:20
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Repeat.swift:29
    typealias Parent = RepeatElement<O.E>
ReplaySubject.swift:126
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
ReplaySubject.swift:131
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
RetryWhen.swift:41
    typealias E = O.E
RetryWhen.swift:84
    typealias Element = O.E
RetryWhen.swift:145
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Sample.swift:69
    typealias Element = O.E
Sample.swift:124
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Scan.swift:59
    override func run<O : ObserverType where O.E == Accumulate>(observer: O) -> Disposable {
Sequence.swift:12
    typealias Parent = Sequence<O.E>
Sequence.swift:43
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1.swift:33
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1.swift:38
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1WhileConnected.swift:31
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ShareReplay1WhileConnected.swift:36
    func _synchronized_subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
SingleAsync.swift:71
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Sink.swift:21
    final func forwardOn(event: Event<O.E>) {
Sink.swift:40
    typealias E = O.E
Skip.swift:57
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Skip.swift:123
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SkipUntil.swift:120
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SkipWhile.swift:103
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
StartWith.swift:21
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SubscribeOn.swift:12
    typealias Element = O.E
SubscribeOn.swift:55
    override func run<O : ObserverType where O.E == Ob.E>(observer: O) -> Disposable {
Switch.swift:170
    override func run<O : ObserverType where O.E == S.E>(observer: O) -> Disposable {
Switch.swift:188
    override func run<O : ObserverType where O.E == S.E>(observer: O) -> Disposable {
SynchronizedOnType.swift:12
    func _synchronized_on(event: Event<E>)
SynchronizedOnType.swift:16
    func synchronizedOn(event: Event<E>) {
SynchronizedSubscribeType.swift:12
    func _synchronized_subscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable
SynchronizedSubscribeType.swift:16
    func synchronizedSubscribe<O: ObserverType where O.E == E>(observer: O) -> Disposable {
TailRecursiveSink.swift:25
    typealias E = O.E
Take.swift:64
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Take.swift:139
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
TakeLast.swift:58
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
TakeUntil.swift:115
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
TakeWhile.swift:121
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Throttle.swift:16
    typealias Element = O.E
Throttle.swift:98
    override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Timeout.swift:115
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Timer.swift:12
    typealias Parent = Timer<O.E>
Timer.swift:22
        return _parent._scheduler.schedulePeriodic(0 as O.E, startAfter: _parent._dueTime, period: _parent._period!) { state in
Timer.swift:30
    typealias Parent = Timer<O.E>
Timer.swift:60
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ToArray.swift:45
    override func run<O: ObserverType where O.E == [SourceType]>(observer: O) -> Disposable {
Using.swift:14
    typealias E = O.E
Using.swift:73
    override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
Window.swift:147
    override func run<O : ObserverType where O.E == Observable<Element>>(observer: O) -> Disposable {
WithLatestFrom.swift:119
    override func run<O : ObserverType where O.E == ResultType>(observer: O) -> Disposable {
Zip+arity.swift:37
    typealias R = O.E
Zip+arity.swift:98
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:130
    typealias R = O.E
Zip+arity.swift:199
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:231
    typealias R = O.E
Zip+arity.swift:308
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:340
    typealias R = O.E
Zip+arity.swift:425
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:457
    typealias R = O.E
Zip+arity.swift:550
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:582
    typealias R = O.E
Zip+arity.swift:683
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:715
    typealias R = O.E
Zip+arity.swift:824
    override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+CollectionType.swift:132
    override func run<O : ObserverType where O.E == R>(observer: O) -> Disposable {
Zip.swift:19
    typealias Element = O.E

0019    
0020        /**
0021        Notify observer about sequence event.
0022        
0023        - parameter event: Event that occured.
0024        */
0025        func on
AnyObserver.swift:44
        self.observer = observer.on
Bag.swift:271
            _value0?.on(event)
Bag.swift:281
            value0.on(event)
Bag.swift:285
            value1.on(event)
Bag.swift:289
            pairs[i].value.on(event)
Bag.swift:294
                element.on(event)
BehaviorSubject.swift:108
            observer.on(.Error(RxError.Disposed(object: self)))
BehaviorSubject.swift:113
            observer.on(stoppedEvent)
BehaviorSubject.swift:118
        observer.on(.Next(_value))
Empty.swift:13
        observer.on(.Completed)
Error.swift:19
        observer.on(.Error(_error))
Just.swift:57
        observer.on(.Next(_element))
Just.swift:58
        observer.on(.Completed)
ObserveOn.swift:94
            observer?.on(nextEvent)
ObserveOnSerialDispatchQueue.swift:34
            sink.observer.on(event)
ObserverType.swift:39
        on(.Next(element))
ObserverType.swift:46
        on(.Completed)
ObserverType.swift:54
        on(.Error(error))
PublishSubject.swift:91
            observer.on(stoppedEvent)
PublishSubject.swift:96
            observer.on(.Error(RxError.Disposed(object: self)))
ReplaySubject.swift:133
            observer.on(.Error(RxError.Disposed(object: self)))
ReplaySubject.swift:141
            observer.on(stoppedEvent)
Sequence.swift:47
                observer.on(.Next(element))
Sequence.swift:50
            observer.on(.Completed)
ShareReplay1.swift:40
            observer.on(.Next(element))
ShareReplay1.swift:44
            observer.on(stopEvent)
ShareReplay1WhileConnected.swift:38
            observer.on(.Next(element))
Sink.swift:25
        _observer.on(event)
Sink.swift:51
            _forward._observer.on(event)
Sink.swift:53
            _forward._observer.on(event)
StartWith.swift:23
            observer.on(.Next(e))
(event: Event<E>)
0026    }
0027    
0028    /**
0029    Convenience API extensions to provide alternate next, error, completed events
0030    */
0031    public extension ObserverType {
0032        
0033        /**
0034        Convenience method equivalent to `on(.Next(element: E))`
0035        
0036        - parameter element: Next element to send to observer(s)
0037        */
0038        final func onNext(element: E) {
0039            on(.Next(element))
0040        }
0041        
0042        /**
0043        Convenience method equivalent to `on(.Completed)`
0044        */
0045        final func onCompleted() {
0046            on(.Completed)
0047        }
0048        
0049        /**
0050        Convenience method equivalent to `on(.Error(error: ErrorType))`
0051        - parameter error: ErrorType to send to observer(s)
0052        */
0053        final func onError(error: ErrorType) {
0054            on(.Error(error))
0055        }
0056    }
0057