0001    //
0002    //  Sink.swift
0003    //  Rx
0004    //
0005    //  Created by Krunoslav Zaher on 2/19/15.
0006    //  Copyright © 2015 Krunoslav Zaher. All rights reserved.
0007    //
0008    
0009    import Foundation
0010    
0011    class Sink
AddRef.swift:11
class AddRefSink<O: ObserverType> : Sink<O>, ObserverType {
Amb.swift:51
class AmbSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O> {
AnonymousObservable.swift:11
class AnonymousObservableSink<O: ObserverType> : Sink<O>, ObserverType {
Buffer.swift:33
    : Sink<O>
Catch.swift:35
class CatchSink<O: ObserverType> : Sink<O>, ObserverType {
CombineLatest+CollectionType.swift:12
    : Sink<O> {
CombineLatest.swift:18
    : Sink<O>
Debug.swift:17
class Debug_<O: ObserverType> : Sink<O>, ObserverType {
Deferred.swift:11
class DeferredSink<S: ObservableType, O: ObserverType where S.E == O.E> : Sink<O>, ObserverType {
DelaySubscription.swift:12
    : Sink<O>
DistinctUntilChanged.swift:11
class DistinctUntilChangedSink<O: ObserverType, Key>: Sink<O>, ObserverType {
Do.swift:11
class DoSink<O: ObserverType> : Sink<O>, ObserverType {
ElementAt.swift:12
class ElementAtSink<SourceType, O: ObserverType where O.E == SourceType> : Sink<O>, ObserverType {
Filter.swift:11
class FilterSink<O : ObserverType>: Sink<O>, ObserverType {
Generate.swift:11
class GenerateSink<S, O: ObserverType> : Sink<O> {
Just.swift:11
class JustScheduledSink<O: ObserverType> : Sink<O> {
Map.swift:11
class MapSink<SourceType, O : ObserverType> : Sink<O>, ObserverType {
Map.swift:45
class MapWithIndexSink<SourceType, O : ObserverType> : Sink<O>, ObserverType {
Merge.swift:62
    : Sink<O>
Merge.swift:274
    : Sink<O>
Multicast.swift:11
class MulticastSink<S: SubjectType, O: ObserverType>: Sink<O>, ObserverType {
Range.swift:37
class RangeSink<O: ObserverType where O.E: SignedIntegerType> : Sink<O> {
Reduce.swift:11
class ReduceSink<SourceType, AccumulateType, O: ObserverType> : Sink<O>, ObserverType {
RefCount.swift:12
    : Sink<O>
Repeat.swift:28
class RepeatElementSink<O: ObserverType> : Sink<O> {
Sample.swift:65
    : Sink<O>
Scan.swift:11
class ScanSink<ElementType, Accumulate, O: ObserverType where O.E == Accumulate> : Sink<O>, ObserverType {
Sequence.swift:11
class SequenceSink<O: ObserverType> : Sink<O> {
SingleAsync.swift:11
class SingleAsyncSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
Sink.swift:42
    private let _forward: Sink<O>
Sink.swift:44
    init(forward: Sink<O>) {
Skip.swift:13
class SkipCountSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
Skip.swift:67
class SkipTimeSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
SkipUntil.swift:60
    : Sink<O>
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 {
SubscribeOn.swift:11
class SubscribeOnSink<Ob: ObservableType, O: ObserverType where Ob.E == O.E> : Sink<O>, ObserverType {
Switch.swift:12
    : Sink<O>
TailRecursiveSink.swift:22
    : Sink<O>
Take.swift:13
class TakeCountSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
Take.swift:74
    : Sink<O>
TakeLast.swift:12
class TakeLastSink<ElementType, O: ObserverType where O.E == ElementType> : Sink<O>, ObserverType {
TakeUntil.swift:59
    : Sink<O>
TakeWhile.swift:12
    : Sink<O>
TakeWhile.swift:56
    : Sink<O>
Throttle.swift:12
    : Sink<O>
Timeout.swift:11
class TimeoutSink<ElementType, O: ObserverType where O.E == ElementType>: Sink<O>, LockOwnerType, ObserverType {
Timer.swift:11
class TimerSink<O: ObserverType where O.E : SignedIntegerType > : Sink<O> {
Timer.swift:29
class TimerOneOffSink<O: ObserverType where O.E : SignedIntegerType> : Sink<O> {
ToArray.swift:11
class ToArraySink<SourceType, O: ObserverType where O.E == [SourceType]> : Sink<O>, ObserverType {
Using.swift:11
class UsingSink<SourceType, ResourceType: Disposable, O: ObserverType where O.E == SourceType> : Sink<O>, ObserverType {
Window.swift:12
    : Sink<O>
WithLatestFrom.swift:12
    : Sink<O>
Zip+CollectionType.swift:12
    : Sink<O> {
Zip.swift:18
class ZipSink<O: ObserverType> : Sink<O>, ZipSinkProtocol {
<O
Sink.swift:12
    private let _observer: O
Sink.swift:14
    init(observer: O) {
Sink.swift:21
    final func forwardOn(event: Event<O.E>) {
Sink.swift:28
    final func forwarder() -> SinkForward<O> {
 : ObserverType> : SingleAssignmentDisposable {
0012        private let _observer
Sink.swift:18
        _observer = observer
Sink.swift:25
        _observer.on(event)
Sink.swift:51
            _forward._observer.on(event)
Sink.swift:53
            _forward._observer.on(event)
: O
0013    
0014        init
AddRef.swift:15
        super.init(observer: observer)
Amb.swift:63
        super.init(observer: observer)
AnonymousObservable.swift:19
        super.init(observer: observer)
Buffer.swift:51
        super.init(observer: observer)
Catch.swift:44
        super.init(observer: observer)
CombineLatest+CollectionType.swift:38
        super.init(observer: observer)
CombineLatest.swift:35
        super.init(observer: observer)
Debug.swift:30
        super.init(observer: observer)
Deferred.swift:18
        super.init(observer: observer)
DelaySubscription.swift:21
        super.init(observer: observer)
DistinctUntilChanged.swift:19
        super.init(observer: observer)
Do.swift:19
        super.init(observer: observer)
ElementAt.swift:22
        super.init(observer: observer)
Filter.swift:21
        super.init(observer: observer)
Generate.swift:21
        super.init(observer: observer)
Just.swift:18
        super.init(observer: observer)
Map.swift:21
        super.init(observer: observer)
Map.swift:58
        super.init(observer: observer)
Merge.swift:85
        super.init(observer: observer)
Merge.swift:292
        super.init(observer: observer)
Multicast.swift:20
        super.init(observer: observer)
Range.swift:44
        super.init(observer: observer)
Reduce.swift:22
        super.init(observer: observer)
RefCount.swift:21
        super.init(observer: observer)
Repeat.swift:35
        super.init(observer: observer)
Sample.swift:84
        super.init(observer: observer)
Scan.swift:21
        super.init(observer: observer)
Sequence.swift:18
        super.init(observer: observer)
SingleAsync.swift:20
        super.init(observer: observer)
Skip.swift:24
        super.init(observer: observer)
Skip.swift:78
        super.init(observer: observer)
SkipUntil.swift:75
        super.init(observer: observer)
SkipWhile.swift:19
        super.init(observer: observer)
SkipWhile.swift:56
        super.init(observer: observer)
SubscribeOn.swift:19
        super.init(observer: observer)
Switch.swift:29
        super.init(observer: observer)
TailRecursiveSink.swift:36
        super.init(observer: observer)
Take.swift:24
        super.init(observer: observer)
Take.swift:87
        super.init(observer: observer)
TakeLast.swift:23
        super.init(observer: observer)
TakeUntil.swift:75
        super.init(observer: observer)
TakeWhile.swift:23
        super.init(observer: observer)
TakeWhile.swift:68
        super.init(observer: observer)
Throttle.swift:32
        super.init(observer: observer)
Timeout.swift:27
        super.init(observer: observer)
Timer.swift:18
        super.init(observer: observer)
Timer.swift:36
        super.init(observer: observer)
ToArray.swift:20
        super.init(observer: observer)
Using.swift:20
        super.init(observer: observer)
Window.swift:37
        super.init(observer: observer)
WithLatestFrom.swift:28
        super.init(observer: observer)
Zip+CollectionType.swift:38
        super.init(observer: observer)
Zip.swift:32
        super.init(observer: observer)
(observer: O) {
0015    #if TRACE_RESOURCES
0016            AtomicIncrement(&resourceCount)
0017    #endif
0018            _observer = observer
0019        }
0020        
0021        final func forwardOn
AddRef.swift:21
            forwardOn(event)
AddRef.swift:23
            forwardOn(event)
Amb.swift:72
            self.forwardOn(event)
Amb.swift:85
                    self.forwardOn(event)
AnonymousObservable.swift:28
            forwardOn(event)
AnonymousObservable.swift:31
                forwardOn(event)
Buffer.swift:65
        forwardOn(.Next(buffer))
Buffer.swift:85
            forwardOn(.Error(error))
Buffer.swift:88
            forwardOn(.Next(_buffer))
Buffer.swift:89
            forwardOn(.Completed)
Catch.swift:24
        _parent.forwardOn(event)
Catch.swift:58
            forwardOn(event)
Catch.swift:60
            forwardOn(event)
Catch.swift:71
                forwardOn(.Error(e))
Catch.swift:113
            forwardOn(event)
Catch.swift:118
            forwardOn(event)
Catch.swift:129
            forwardOn(.Error(lastError))
Catch.swift:132
            forwardOn(.Completed)
CombineLatest+CollectionType.swift:54
                        forwardOn(.Completed)
CombineLatest+CollectionType.swift:62
                    forwardOn(.Next(result))
CombineLatest+CollectionType.swift:65
                    forwardOn(.Error(error))
CombineLatest+CollectionType.swift:70
                forwardOn(.Error(error))
CombineLatest+CollectionType.swift:81
                    forwardOn(.Completed)
CombineLatest.swift:51
                forwardOn(.Next(result))
CombineLatest.swift:54
                forwardOn(.Error(e))
CombineLatest.swift:69
                forwardOn(.Completed)
CombineLatest.swift:76
        forwardOn(.Error(error))
CombineLatest.swift:89
            forwardOn(.Completed)
Concat.swift:24
            forwardOn(event)
Concat.swift:26
            forwardOn(event)
Debug.swift:41
        forwardOn(event)
Deferred.swift:27
            forwardOn(.Error(e))
Deferred.swift:34
        forwardOn(event)
DelaySubscription.swift:25
        forwardOn(event)
DistinctUntilChanged.swift:38
                forwardOn(event)
DistinctUntilChanged.swift:41
                forwardOn(.Error(error))
DistinctUntilChanged.swift:45
            forwardOn(event)
Do.swift:25
            forwardOn(event)
Do.swift:31
            forwardOn(.Error(error))
ElementAt.swift:30
                forwardOn(event)
ElementAt.swift:31
                forwardOn(.Completed)
ElementAt.swift:38
                forwardOn(.Error(e))
ElementAt.swift:44
            forwardOn(.Error(e))
ElementAt.swift:48
                forwardOn(.Error(RxError.ArgumentOutOfRange))
ElementAt.swift:50
                forwardOn(.Completed)
Filter.swift:30
                        forwardOn(.Next(value))
Filter.swift:34
                    forwardOn(.Error(e))
Filter.swift:38
                forwardOn(event)
Generate.swift:33
                    self.forwardOn(.Next(result))
Generate.swift:38
                    self.forwardOn(.Completed)
Generate.swift:43
                self.forwardOn(.Error(error))
Just.swift:24
            self.forwardOn(.Next(element))
Just.swift:26
                self.forwardOn(.Completed)
Map.swift:29
                forwardOn(.Next(mappedElement))
Map.swift:32
                forwardOn(.Error(e))
Map.swift:36
            forwardOn(.Error(error))
Map.swift:39
            forwardOn(.Completed)
Map.swift:66
                forwardOn(.Next(mappedElement))
Map.swift:69
                forwardOn(.Error(e))
Map.swift:73
            forwardOn(.Error(error))
Map.swift:76
            forwardOn(.Completed)
Merge.swift:40
            _parent.forwardOn(event)
Merge.swift:42
            _parent.forwardOn(event)
Merge.swift:53
                    _parent.forwardOn(.Completed)
Merge.swift:130
            forwardOn(.Error(error))
Merge.swift:134
                forwardOn(.Completed)
Merge.swift:248
                _parent.forwardOn(.Next(value))
Merge.swift:252
                _parent.forwardOn(.Error(error))
Merge.swift:264
                    _parent.forwardOn(.Completed)
Merge.swift:310
                forwardOn(.Error(e))
Merge.swift:315
                forwardOn(.Error(error))
Merge.swift:322
                    forwardOn(.Completed)
Multicast.swift:36
            forwardOn(.Error(e))
Multicast.swift:43
        forwardOn(event)
Range.swift:50
                self.forwardOn(.Next(self._parent._start + i))
Range.swift:54
                self.forwardOn(.Completed)
Reduce.swift:32
                forwardOn(.Error(e))
Reduce.swift:36
            forwardOn(.Error(e))
Reduce.swift:41
                forwardOn(.Next(result))
Reduce.swift:42
                forwardOn(.Completed)
Reduce.swift:46
                forwardOn(.Error(e))
RefCount.swift:58
            forwardOn(event)
RefCount.swift:60
            forwardOn(event)
Repeat.swift:40
            self.forwardOn(.Next(e))
RetryWhen.swift:29
            _parent._parent.forwardOn(.Error(e))
RetryWhen.swift:32
            _parent._parent.forwardOn(.Completed)
RetryWhen.swift:54
            _parent.forwardOn(event)
RetryWhen.swift:67
                _parent.forwardOn(.Error(error))
RetryWhen.swift:71
            _parent.forwardOn(event)
RetryWhen.swift:104
            forwardOn(.Error(lastError))
RetryWhen.swift:108
            forwardOn(.Completed)
Sample.swift:41
                _parent.forwardOn(.Next(element))
Sample.swift:45
                _parent.forwardOn(.Completed)
Sample.swift:49
            _parent.forwardOn(.Error(e))
Sample.swift:54
                _parent.forwardOn(.Next(element))
Sample.swift:57
                _parent.forwardOn(.Completed)
Sample.swift:103
            forwardOn(event)
Scan.swift:29
                forwardOn(.Next(_accumulate))
Scan.swift:32
                forwardOn(.Error(error))
Scan.swift:36
            forwardOn(.Error(error))
Scan.swift:39
            forwardOn(.Completed)
Sequence.swift:24
                self.forwardOn(.Next(state.1[state.0]))
Sequence.swift:28
                self.forwardOn(.Completed)
SingleAsync.swift:33
                forwardOn(.Error(error as ErrorType))
SingleAsync.swift:39
                forwardOn(.Next(value))
SingleAsync.swift:42
                forwardOn(.Error(RxError.MoreThanOneElement))
SingleAsync.swift:47
            forwardOn(event)
SingleAsync.swift:51
                forwardOn(.Error(RxError.NoElements))
SingleAsync.swift:53
                forwardOn(.Completed)
Skip.swift:32
                forwardOn(.Next(value))
Skip.swift:38
            forwardOn(event)
Skip.swift:41
            forwardOn(event)
Skip.swift:85
                forwardOn(.Next(value))
Skip.swift:88
            forwardOn(event)
Skip.swift:91
            forwardOn(event)
SkipUntil.swift:43
            _parent.forwardOn(.Error(e))
SkipUntil.swift:86
                forwardOn(event)
SkipUntil.swift:89
            forwardOn(event)
SkipUntil.swift:93
                forwardOn(event)
SkipWhile.swift:29
                    forwardOn(.Error(e))
SkipWhile.swift:36
                forwardOn(.Next(value))
SkipWhile.swift:39
            forwardOn(event)
SkipWhile.swift:67
                    forwardOn(.Error(e))
SkipWhile.swift:74
                forwardOn(.Next(value))
SkipWhile.swift:77
            forwardOn(event)
SubscribeOn.swift:23
        forwardOn(event)
Switch.swift:63
                forwardOn(.Error(error))
Switch.swift:67
            forwardOn(.Error(error))
Switch.swift:75
                forwardOn(.Completed)
Switch.swift:120
            _parent.forwardOn(event)
Switch.swift:122
            _parent.forwardOn(event)
Switch.swift:127
                _parent.forwardOn(event)
TailRecursiveSink.swift:62
        forwardOn(.Completed)
Take.swift:34
                forwardOn(.Next(value))
Take.swift:37
                    forwardOn(.Completed)
Take.swift:42
            forwardOn(event)
Take.swift:45
            forwardOn(event)
Take.swift:97
            forwardOn(.Next(value))
Take.swift:99
            forwardOn(event)
Take.swift:102
            forwardOn(event)
Take.swift:110
        forwardOn(.Completed)
TakeLast.swift:34
            forwardOn(event)
TakeLast.swift:38
                forwardOn(.Next(e))
TakeLast.swift:40
            forwardOn(.Completed)
TakeUntil.swift:40
            _parent.forwardOn(.Completed)
TakeUntil.swift:43
            _parent.forwardOn(.Error(e))
TakeUntil.swift:85
            forwardOn(event)
TakeUntil.swift:87
            forwardOn(event)
TakeUntil.swift:90
            forwardOn(event)
TakeWhile.swift:36
                forwardOn(.Error(e))
TakeWhile.swift:42
                forwardOn(.Next(value))
TakeWhile.swift:44
                forwardOn(.Completed)
TakeWhile.swift:48
            forwardOn(event)
TakeWhile.swift:82
                forwardOn(.Error(e))
TakeWhile.swift:88
                forwardOn(.Next(value))
TakeWhile.swift:90
                forwardOn(.Completed)
TakeWhile.swift:94
            forwardOn(event)
Throttle.swift:61
            forwardOn(event)
Throttle.swift:66
                forwardOn(.Next(value))
Throttle.swift:68
            forwardOn(.Completed)
Throttle.swift:79
                forwardOn(.Next(value))
Timeout.swift:54
                forwardOn(event)
Timeout.swift:68
                forwardOn(event)
Timer.swift:23
            self.forwardOn(.Next(state))
Timer.swift:41
            self.forwardOn(.Next(0))
Timer.swift:42
            self.forwardOn(.Completed)
ToArray.swift:28
            forwardOn(.Error(e))
ToArray.swift:31
            forwardOn(.Next(_list))
ToArray.swift:32
            forwardOn(.Completed)
Using.swift:46
            forwardOn(.Next(value))
Using.swift:48
            forwardOn(.Error(error))
Using.swift:51
            forwardOn(.Completed)
Window.swift:42
        forwardOn(.Next(AddRef(source: _subject, refCount: _refCountDisposable).asObservable()))
Window.swift:53
        forwardOn(.Next(AddRef(source: _subject, refCount: _refCountDisposable).asObservable()))
Window.swift:85
            forwardOn(.Error(error))
Window.swift:89
            forwardOn(.Completed)
WithLatestFrom.swift:52
                forwardOn(.Next(res))
WithLatestFrom.swift:54
                forwardOn(.Error(e))
WithLatestFrom.swift:58
            forwardOn(.Completed)
WithLatestFrom.swift:61
            forwardOn(.Error(error))
WithLatestFrom.swift:100
            _parent.forwardOn(.Error(error))
Zip+CollectionType.swift:54
                        self.forwardOn(.Completed)
Zip+CollectionType.swift:75
                    self.forwardOn(.Next(result))
Zip+CollectionType.swift:78
                    self.forwardOn(.Error(error))
Zip+CollectionType.swift:83
                self.forwardOn(.Error(error))
Zip+CollectionType.swift:94
                    self.forwardOn(.Completed)
Zip.swift:56
                self.forwardOn(.Next(result))
Zip.swift:59
                self.forwardOn(.Error(e))
Zip.swift:75
                forwardOn(.Completed)
Zip.swift:82
        forwardOn(.Error(error))
Zip.swift:99
            forwardOn(.Completed)
(event: Event<O.E>) {
0022            if disposed {
0023                return
0024            }
0025            _observer.on(event)
0026        }
0027        
0028        final func forwarder
Timeout.swift:92
                self._subscription.disposable = self._parent._other.subscribeSafe(self.forwarder())
() -> SinkForward<O> {
0029            return SinkForward(forward: self)
0030        }
0031    
0032        deinit {
0033    #if TRACE_RESOURCES
0034            AtomicDecrement(&resourceCount)
0035    #endif
0036        }
0037    }
0038    
0039    class SinkForward
Sink.swift:28
    final func forwarder() -> SinkForward<O> {
Sink.swift:29
        return SinkForward(forward: self)
<O
Sink.swift:40
    typealias E = O.E
Sink.swift:42
    private let _forward: Sink<O>
Sink.swift:44
    init(forward: Sink<O>) {
: ObserverType>: ObserverType {
0040        typealias E
Sink.swift:48
    func on(event: Event<E>) {
 = O.E
0041        
0042        private let _forward
Sink.swift:45
        _forward = forward
Sink.swift:51
            _forward._observer.on(event)
Sink.swift:53
            _forward._observer.on(event)
Sink.swift:54
            _forward.dispose()
: Sink<O>
0043        
0044        init
Sink.swift:29
        return SinkForward(forward: self)
(forward: Sink<O>) {
0045            _forward = forward
0046        }
0047        
0048        func on(event: Event<E>) {
0049            switch event {
0050            case .Next:
0051                _forward._observer.on(event)
0052            case .Error, .Completed:
0053                _forward._observer.on(event)
0054                _forward.dispose()
0055            }
0056        }
0057    }