0001 // 0002 // SingleAssignmentDisposable.swift 0003 // Rx 0004 // 0005 // Created by Krunoslav Zaher on 2/15/15. 0006 // Copyright © 2015 Krunoslav Zaher. All rights reserved. 0007 // 0008 0009 import Foundation 0010 0011 /** 0012 Represents a disposable resource which only allows a single assignment of its underlying disposable resource. 0013 0014 If an underlying disposable resource has already been set, future attempts to set the underlying disposable resource will throw an exception. 0015 */ 0016 public class SingleAssignmentDisposable: DisposeBase, Disposable, Cancelable { 0017 private var _lock
Amb.swift:67 let subscription1 = SingleAssignmentDisposable()Amb.swift:68 let subscription2 = SingleAssignmentDisposable()Buffer.swift:103 let nextTimer = SingleAssignmentDisposable()Catch.swift:48 let d1 = SingleAssignmentDisposable()CombineLatest+arity.swift:51 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:52 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:133 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:134 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:135 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:222 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:223 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:224 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:225 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:318 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:319 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:320 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:321 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:322 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:421 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:422 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:423 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:424 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:425 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:426 let subscription6 = SingleAssignmentDisposable()CombineLatest+arity.swift:531 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:532 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:533 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:534 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:535 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:536 let subscription6 = SingleAssignmentDisposable()CombineLatest+arity.swift:537 let subscription7 = SingleAssignmentDisposable()CombineLatest+arity.swift:648 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:649 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:650 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:651 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:652 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:653 let subscription6 = SingleAssignmentDisposable()CombineLatest+arity.swift:654 let subscription7 = SingleAssignmentDisposable()CombineLatest+arity.swift:655 let subscription8 = SingleAssignmentDisposable()CombineLatest+CollectionType.swift:25 var _subscriptions: [SingleAssignmentDisposable]CombineLatest+CollectionType.swift:31 _subscriptions = Array<SingleAssignmentDisposable>()CombineLatest+CollectionType.swift:35 _subscriptions.append(SingleAssignmentDisposable())ConcurrentDispatchQueueScheduler.swift:72 let cancel = SingleAssignmentDisposable()ConcurrentMainScheduler.swift:55 let cancel = SingleAssignmentDisposable()ImmediateScheduler.swift:29 let disposable = SingleAssignmentDisposable()MainScheduler.swift:55 let cancel = SingleAssignmentDisposable()Merge.swift:78 private let _sourceSubscription = SingleAssignmentDisposable()Merge.swift:97 let subscription = SingleAssignmentDisposable()Merge.swift:287 private let _sourceSubscription = SingleAssignmentDisposable()Merge.swift:333 let iterDisposable = SingleAssignmentDisposable()ObserveOn.swift:57 let _subscription = SingleAssignmentDisposable()ObserveOnSerialDispatchQueue.swift:24 let subscription = SingleAssignmentDisposable()RetryWhen.swift:39 : SingleAssignmentDisposableRetryWhen.swift:45 private let _errorHandlerSubscription = SingleAssignmentDisposable()Sample.swift:80 private let _sourceSubscription = SingleAssignmentDisposable()ScheduledItem.swift:19 private let _disposable = SingleAssignmentDisposable()SerialDispatchQueueScheduler.swift:108 let cancel = SingleAssignmentDisposable()ShareReplay1.swift:23 private var _connection: SingleAssignmentDisposable?ShareReplay1.swift:53 let connection = SingleAssignmentDisposable()ShareReplay1WhileConnected.swift:23 private var _connection: SingleAssignmentDisposable?ShareReplay1WhileConnected.swift:46 let connection = SingleAssignmentDisposable()Sink.swift:11 class Sink<O : ObserverType> : SingleAssignmentDisposable {SkipUntil.swift:24 let _subscription = SingleAssignmentDisposable()SkipUntil.swift:71 private let _sourceSubscription = SingleAssignmentDisposable()SubscribeOn.swift:32 let cancelSchedule = SingleAssignmentDisposable()Switch.swift:18 private let _subscriptions: SingleAssignmentDisposable = SingleAssignmentDisposable()Switch.swift:18 private let _subscriptions: SingleAssignmentDisposable = SingleAssignmentDisposable()Switch.swift:55 let d = SingleAssignmentDisposable()TailRecursiveSink.swift:130 let disposable = SingleAssignmentDisposable()TakeUntil.swift:24 private let _subscription = SingleAssignmentDisposable()Throttle.swift:56 let d = SingleAssignmentDisposable()Timeout.swift:31 let original = SingleAssignmentDisposable()Timeout.swift:79 let nextTimer = SingleAssignmentDisposable()VirtualTimeScheduler.swift:274 var disposable = SingleAssignmentDisposable()Window.swift:107 let nextTimer = SingleAssignmentDisposable()WithLatestFrom.swift:32 let sndSubscription = SingleAssignmentDisposable()Zip+arity.swift:63 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:64 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:158 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:159 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:160 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:261 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:262 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:263 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:264 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:372 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:373 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:374 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:375 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:376 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:491 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:492 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:493 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:494 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:495 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:496 let subscription6 = SingleAssignmentDisposable()Zip+arity.swift:618 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:619 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:620 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:621 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:622 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:623 let subscription6 = SingleAssignmentDisposable()Zip+arity.swift:624 let subscription7 = SingleAssignmentDisposable()Zip+arity.swift:753 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:754 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:755 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:756 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:757 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:758 let subscription6 = SingleAssignmentDisposable()Zip+arity.swift:759 let subscription7 = SingleAssignmentDisposable()Zip+arity.swift:760 let subscription8 = SingleAssignmentDisposable()Zip+CollectionType.swift:25 private var _subscriptions: [SingleAssignmentDisposable]Zip+CollectionType.swift:31 _subscriptions = Array<SingleAssignmentDisposable>()Zip+CollectionType.swift:35 _subscriptions.append(SingleAssignmentDisposable())= SpinLock() 0018 0019 // state 0020 private var _disposed
SingleAssignmentDisposable.swift:47 _lock.lock(); defer { _lock.unlock() }SingleAssignmentDisposable.swift:47 _lock.lock(); defer { _lock.unlock() }SingleAssignmentDisposable.swift:82 _lock.lock(); defer { _lock.unlock() }SingleAssignmentDisposable.swift:82 _lock.lock(); defer { _lock.unlock() }= false 0021 private var _disposableSet
SingleAssignmentDisposable.swift:29 return _disposedSingleAssignmentDisposable.swift:62 if _disposed {SingleAssignmentDisposable.swift:75 if _disposed {SingleAssignmentDisposable.swift:84 _disposed = true= false 0022 private var _disposable
SingleAssignmentDisposable.swift:56 if _disposableSet {SingleAssignmentDisposable.swift:60 _disposableSet = true= nil as Disposable? 0023 0024 /** 0025 - returns: A value that indicates whether the object is disposed. 0026 */ 0027 public var disposed
SingleAssignmentDisposable.swift:48 return _disposable ?? NopDisposable.instanceSingleAssignmentDisposable.swift:66 _disposable = newValueSingleAssignmentDisposable.swift:85 let disposable = _disposableSingleAssignmentDisposable.swift:86 _disposable = nil: Bool { 0028 get { 0029 return _disposed 0030 } 0031 } 0032 0033 /** 0034 Initializes a new instance of the `SingleAssignmentDisposable`. 0035 */ 0036 public override init
ConcurrentDispatchQueueScheduler.swift:75 if cancel.disposed {ConcurrentMainScheduler.swift:58 if cancel.disposed {ImmediateScheduler.swift:31 if disposable.disposed {MainScheduler.swift:58 if !cancel.disposed {ScheduledItem.swift:23 return _disposable.disposedSerialDispatchQueueScheduler.swift:111 if cancel.disposed {Sink.swift:22 if disposed {VirtualTimeScheduler.swift:270 return disposable.disposed() { 0037 super.init() 0038 } 0039 0040 /** 0041 Gets or sets the underlying disposable. After disposal, the result of getting this property is undefined. 0042 0043 **Throws exception if the `SingleAssignmentDisposable` has already been assigned to.** 0044 */ 0045 public var disposable
Amb.swift:67 let subscription1 = SingleAssignmentDisposable()Amb.swift:68 let subscription2 = SingleAssignmentDisposable()Buffer.swift:103 let nextTimer = SingleAssignmentDisposable()Catch.swift:48 let d1 = SingleAssignmentDisposable()CombineLatest+arity.swift:51 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:52 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:133 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:134 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:135 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:222 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:223 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:224 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:225 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:318 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:319 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:320 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:321 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:322 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:421 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:422 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:423 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:424 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:425 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:426 let subscription6 = SingleAssignmentDisposable()CombineLatest+arity.swift:531 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:532 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:533 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:534 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:535 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:536 let subscription6 = SingleAssignmentDisposable()CombineLatest+arity.swift:537 let subscription7 = SingleAssignmentDisposable()CombineLatest+arity.swift:648 let subscription1 = SingleAssignmentDisposable()CombineLatest+arity.swift:649 let subscription2 = SingleAssignmentDisposable()CombineLatest+arity.swift:650 let subscription3 = SingleAssignmentDisposable()CombineLatest+arity.swift:651 let subscription4 = SingleAssignmentDisposable()CombineLatest+arity.swift:652 let subscription5 = SingleAssignmentDisposable()CombineLatest+arity.swift:653 let subscription6 = SingleAssignmentDisposable()CombineLatest+arity.swift:654 let subscription7 = SingleAssignmentDisposable()CombineLatest+arity.swift:655 let subscription8 = SingleAssignmentDisposable()CombineLatest+CollectionType.swift:35 _subscriptions.append(SingleAssignmentDisposable())ConcurrentDispatchQueueScheduler.swift:72 let cancel = SingleAssignmentDisposable()ConcurrentMainScheduler.swift:55 let cancel = SingleAssignmentDisposable()ImmediateScheduler.swift:29 let disposable = SingleAssignmentDisposable()MainScheduler.swift:55 let cancel = SingleAssignmentDisposable()Merge.swift:78 private let _sourceSubscription = SingleAssignmentDisposable()Merge.swift:97 let subscription = SingleAssignmentDisposable()Merge.swift:287 private let _sourceSubscription = SingleAssignmentDisposable()Merge.swift:333 let iterDisposable = SingleAssignmentDisposable()ObserveOn.swift:57 let _subscription = SingleAssignmentDisposable()ObserveOnSerialDispatchQueue.swift:24 let subscription = SingleAssignmentDisposable()RetryWhen.swift:45 private let _errorHandlerSubscription = SingleAssignmentDisposable()Sample.swift:80 private let _sourceSubscription = SingleAssignmentDisposable()ScheduledItem.swift:19 private let _disposable = SingleAssignmentDisposable()SerialDispatchQueueScheduler.swift:108 let cancel = SingleAssignmentDisposable()ShareReplay1.swift:53 let connection = SingleAssignmentDisposable()ShareReplay1WhileConnected.swift:46 let connection = SingleAssignmentDisposable()SkipUntil.swift:24 let _subscription = SingleAssignmentDisposable()SkipUntil.swift:71 private let _sourceSubscription = SingleAssignmentDisposable()SubscribeOn.swift:32 let cancelSchedule = SingleAssignmentDisposable()Switch.swift:18 private let _subscriptions: SingleAssignmentDisposable = SingleAssignmentDisposable()Switch.swift:55 let d = SingleAssignmentDisposable()TailRecursiveSink.swift:130 let disposable = SingleAssignmentDisposable()TakeUntil.swift:24 private let _subscription = SingleAssignmentDisposable()Throttle.swift:56 let d = SingleAssignmentDisposable()Timeout.swift:31 let original = SingleAssignmentDisposable()Timeout.swift:79 let nextTimer = SingleAssignmentDisposable()VirtualTimeScheduler.swift:274 var disposable = SingleAssignmentDisposable()Window.swift:107 let nextTimer = SingleAssignmentDisposable()WithLatestFrom.swift:32 let sndSubscription = SingleAssignmentDisposable()Zip+arity.swift:63 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:64 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:158 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:159 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:160 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:261 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:262 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:263 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:264 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:372 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:373 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:374 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:375 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:376 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:491 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:492 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:493 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:494 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:495 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:496 let subscription6 = SingleAssignmentDisposable()Zip+arity.swift:618 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:619 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:620 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:621 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:622 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:623 let subscription6 = SingleAssignmentDisposable()Zip+arity.swift:624 let subscription7 = SingleAssignmentDisposable()Zip+arity.swift:753 let subscription1 = SingleAssignmentDisposable()Zip+arity.swift:754 let subscription2 = SingleAssignmentDisposable()Zip+arity.swift:755 let subscription3 = SingleAssignmentDisposable()Zip+arity.swift:756 let subscription4 = SingleAssignmentDisposable()Zip+arity.swift:757 let subscription5 = SingleAssignmentDisposable()Zip+arity.swift:758 let subscription6 = SingleAssignmentDisposable()Zip+arity.swift:759 let subscription7 = SingleAssignmentDisposable()Zip+arity.swift:760 let subscription8 = SingleAssignmentDisposable()Zip+CollectionType.swift:35 _subscriptions.append(SingleAssignmentDisposable()): Disposable { 0046 get { 0047 _lock.lock(); defer { _lock.unlock() } 0048 return _disposable ?? NopDisposable.instance 0049 } 0050 set { 0051 _setDisposable(newValue)?.dispose() 0052 } 0053 } 0054 0055 private func _setDisposable
AddRef.swift:43 sink.disposable = StableCompositeDisposable.create(releaseDisposable, _source.subscribeSafe(sink))Amb.swift:101 subscription1.disposable = _parent._left.subscribe(sink1)Amb.swift:102 subscription2.disposable = _parent._right.subscribe(sink2)Amb.swift:119 sink.disposable = sink.run()AnonymousObservable.swift:53 sink.disposable = sink.run(self)Buffer.swift:27 sink.disposable = sink.run()Buffer.swift:107 nextTimer.disposable = _parent._scheduler.scheduleRelative(windowID, dueTime: _parent._timeSpan) { previousWindowID inCatch.swift:50 d1.disposable = _parent._source.subscribe(self)Catch.swift:91 sink.disposable = sink.run()Catch.swift:159 sink.disposable = sink.run((self.sources.generate(), nil))CombineLatest+arity.swift:57 subscription1.disposable = _parent._source1.subscribe(observer1)CombineLatest+arity.swift:58 subscription2.disposable = _parent._source2.subscribe(observer2)CombineLatest+arity.swift:88 sink.disposable = sink.run()CombineLatest+arity.swift:141 subscription1.disposable = _parent._source1.subscribe(observer1)CombineLatest+arity.swift:142 subscription2.disposable = _parent._source2.subscribe(observer2)CombineLatest+arity.swift:143 subscription3.disposable = _parent._source3.subscribe(observer3)CombineLatest+arity.swift:176 sink.disposable = sink.run()CombineLatest+arity.swift:232 subscription1.disposable = _parent._source1.subscribe(observer1)CombineLatest+arity.swift:233 subscription2.disposable = _parent._source2.subscribe(observer2)CombineLatest+arity.swift:234 subscription3.disposable = _parent._source3.subscribe(observer3)CombineLatest+arity.swift:235 subscription4.disposable = _parent._source4.subscribe(observer4)CombineLatest+arity.swift:271 sink.disposable = sink.run()CombineLatest+arity.swift:330 subscription1.disposable = _parent._source1.subscribe(observer1)CombineLatest+arity.swift:331 subscription2.disposable = _parent._source2.subscribe(observer2)CombineLatest+arity.swift:332 subscription3.disposable = _parent._source3.subscribe(observer3)CombineLatest+arity.swift:333 subscription4.disposable = _parent._source4.subscribe(observer4)CombineLatest+arity.swift:334 subscription5.disposable = _parent._source5.subscribe(observer5)CombineLatest+arity.swift:373 sink.disposable = sink.run()CombineLatest+arity.swift:435 subscription1.disposable = _parent._source1.subscribe(observer1)CombineLatest+arity.swift:436 subscription2.disposable = _parent._source2.subscribe(observer2)CombineLatest+arity.swift:437 subscription3.disposable = _parent._source3.subscribe(observer3)CombineLatest+arity.swift:438 subscription4.disposable = _parent._source4.subscribe(observer4)CombineLatest+arity.swift:439 subscription5.disposable = _parent._source5.subscribe(observer5)CombineLatest+arity.swift:440 subscription6.disposable = _parent._source6.subscribe(observer6)CombineLatest+arity.swift:482 sink.disposable = sink.run()CombineLatest+arity.swift:547 subscription1.disposable = _parent._source1.subscribe(observer1)CombineLatest+arity.swift:548 subscription2.disposable = _parent._source2.subscribe(observer2)CombineLatest+arity.swift:549 subscription3.disposable = _parent._source3.subscribe(observer3)CombineLatest+arity.swift:550 subscription4.disposable = _parent._source4.subscribe(observer4)CombineLatest+arity.swift:551 subscription5.disposable = _parent._source5.subscribe(observer5)CombineLatest+arity.swift:552 subscription6.disposable = _parent._source6.subscribe(observer6)CombineLatest+arity.swift:553 subscription7.disposable = _parent._source7.subscribe(observer7)CombineLatest+arity.swift:598 sink.disposable = sink.run()CombineLatest+arity.swift:666 subscription1.disposable = _parent._source1.subscribe(observer1)CombineLatest+arity.swift:667 subscription2.disposable = _parent._source2.subscribe(observer2)CombineLatest+arity.swift:668 subscription3.disposable = _parent._source3.subscribe(observer3)CombineLatest+arity.swift:669 subscription4.disposable = _parent._source4.subscribe(observer4)CombineLatest+arity.swift:670 subscription5.disposable = _parent._source5.subscribe(observer5)CombineLatest+arity.swift:671 subscription6.disposable = _parent._source6.subscribe(observer6)CombineLatest+arity.swift:672 subscription7.disposable = _parent._source7.subscribe(observer7)CombineLatest+arity.swift:673 subscription8.disposable = _parent._source8.subscribe(observer8)CombineLatest+arity.swift:721 sink.disposable = sink.run()CombineLatest+CollectionType.swift:96 _subscriptions[j].disposable = source.subscribe(AnyObserver { event inCombineLatest+CollectionType.swift:122 sink.disposable = sink.run()Concat.swift:60 sink.disposable = sink.run((_sources.generate(), _count))ConcurrentDispatchQueueScheduler.swift:79 cancel.disposable = action(state)ConcurrentMainScheduler.swift:62 cancel.disposable = action(state)Debug.swift:74 sink.disposable = _source.subscribe(sink)Deferred.swift:58 sink.disposable = sink.run()DelaySubscription.swift:46 sink.disposable = _scheduler.scheduleRelative((), dueTime: _dueTime) { _ inDistinctUntilChanged.swift:67 sink.disposable = _source.subscribe(sink)Do.swift:50 sink.disposable = _source.subscribe(sink)ElementAt.swift:76 sink.disposable = _source.subscribeSafe(sink)Filter.swift:57 sink.disposable = _source.subscribe(sink)Generate.swift:68 sink.disposable = sink.run()ImmediateScheduler.swift:34 disposable.disposable = action(state)Just.swift:44 sink.disposable = sink.run()Map.swift:96 sink.disposable = _source.subscribe(sink)Map.swift:131 sink.disposable = _source.subscribe(sink)Merge.swift:92 _sourceSubscription.disposable = disposableMerge.swift:105 subscription.disposable = disposableMerge.swift:157 sink.disposable = sink.run(_source)Merge.swift:337 iterDisposable.disposable = subscriptionMerge.swift:345 _sourceSubscription.disposable = subscriptionMerge.swift:367 sink.disposable = sink.run(_source)Merge.swift:386 sink.disposable = sink.run(_source)Merge.swift:406 sink.disposable = sink.run(_source)Merge.swift:420 sink.disposable = sink.run(_source)Multicast.swift:68 sink.disposable = sink.run()ObserveOn.swift:26 sink._subscription.disposable = source.subscribe(sink)ObserveOnSerialDispatchQueue.swift:71 sink.subscription.disposable = source.subscribe(sink)Range.swift:32 sink.disposable = sink.run()Reduce.swift:71 sink.disposable = _source.subscribe(sink)RefCount.swift:81 sink.disposable = sink.run()Repeat.swift:22 sink.disposable = sink.run()RetryWhen.swift:63 _errorHandlerSubscription.disposable = errorHandlerSubscriptionRetryWhen.swift:123 iter.disposable = source.subscribe(iter)RetryWhen.swift:147 sink.disposable = sink.run((self._sources.generate(), nil))Sample.swift:88 _sourceSubscription.disposable = _parent._source.subscribe(self)Sample.swift:126 sink.disposable = sink.run()Scan.swift:61 sink.disposable = _source.subscribe(sink)ScheduledItem.swift:33 _disposable.disposable = _action(_state)Sequence.swift:55 sink.disposable = sink.run()SerialDispatchQueueScheduler.swift:116 cancel.disposable = action(state)ShareReplay1.swift:56 connection.disposable = self._source.subscribe(self)ShareReplay1WhileConnected.swift:49 connection.disposable = self._source.subscribe(self)SingleAsync.swift:73 sink.disposable = _source.subscribe(sink)Skip.swift:59 sink.disposable = source.subscribe(sink)Skip.swift:125 sink.disposable = sink.run()SkipUntil.swift:103 _sourceSubscription.disposable = sourceSubscriptionSkipUntil.swift:104 otherObserver._subscription.disposable = otherSubscriptionSkipUntil.swift:122 sink.disposable = sink.run()SkipWhile.swift:106 sink.disposable = _source.subscribe(sink)SkipWhile.swift:111 sink.disposable = _source.subscribe(sink)SubscribeOn.swift:36 cancelSchedule.disposable = parent.scheduler.schedule(()) { (_) -> Disposable inSubscribeOn.swift:57 sink.disposable = sink.run()Switch.swift:34 _subscriptions.disposable = subscriptionSwitch.swift:60 d.disposable = disposableSwitch.swift:172 sink.disposable = sink.run(_source)Switch.swift:190 sink.disposable = sink.run(_source)TailRecursiveSink.swift:132 disposable.disposable = subscribeToNext(next!)Take.swift:66 sink.disposable = _source.subscribe(sink)Take.swift:141 sink.disposable = sink.run()TakeLast.swift:60 sink.disposable = _source.subscribe(sink)TakeUntil.swift:98 otherObserver._subscription.disposable = otherSubscriptionTakeUntil.swift:117 sink.disposable = sink.run()TakeWhile.swift:124 sink.disposable = _source.subscribe(sink)TakeWhile.swift:128 sink.disposable = _source.subscribe(sink)Throttle.swift:58 d.disposable = scheduler.scheduleRelative(currentId, dueTime: dueTime, action: self.propagate)Throttle.swift:100 sink.disposable = sink.run()Timeout.swift:36 original.disposable = _parent._source.subscribeSafe(self)Timeout.swift:82 nextTimer.disposable = _parent._scheduler.scheduleRelative(_id, dueTime: _parent._dueTime) { state inTimeout.swift:117 sink.disposable = sink.run()Timer.swift:63 sink.disposable = sink.run()Timer.swift:68 sink.disposable = sink.run()ToArray.swift:47 sink.disposable = _source.subscribe(sink)Using.swift:75 sink.disposable = sink.run()VirtualTimeScheduler.swift:283 self.disposable.disposable = action()Window.swift:111 nextTimer.disposable = _parent._scheduler.scheduleRelative(windowId, dueTime: _parent._timeSpan) { previousWindowId inWindow.swift:149 sink.disposable = sink.run()WithLatestFrom.swift:35 sndSubscription.disposable = _parent._second.subscribe(sndO)WithLatestFrom.swift:121 sink.disposable = sink.run()Zip+arity.swift:69 subscription1.disposable = _parent.source1.subscribe(observer1)Zip+arity.swift:70 subscription2.disposable = _parent.source2.subscribe(observer2)Zip+arity.swift:100 sink.disposable = sink.run()Zip+arity.swift:166 subscription1.disposable = _parent.source1.subscribe(observer1)Zip+arity.swift:167 subscription2.disposable = _parent.source2.subscribe(observer2)Zip+arity.swift:168 subscription3.disposable = _parent.source3.subscribe(observer3)Zip+arity.swift:201 sink.disposable = sink.run()Zip+arity.swift:271 subscription1.disposable = _parent.source1.subscribe(observer1)Zip+arity.swift:272 subscription2.disposable = _parent.source2.subscribe(observer2)Zip+arity.swift:273 subscription3.disposable = _parent.source3.subscribe(observer3)Zip+arity.swift:274 subscription4.disposable = _parent.source4.subscribe(observer4)Zip+arity.swift:310 sink.disposable = sink.run()Zip+arity.swift:384 subscription1.disposable = _parent.source1.subscribe(observer1)Zip+arity.swift:385 subscription2.disposable = _parent.source2.subscribe(observer2)Zip+arity.swift:386 subscription3.disposable = _parent.source3.subscribe(observer3)Zip+arity.swift:387 subscription4.disposable = _parent.source4.subscribe(observer4)Zip+arity.swift:388 subscription5.disposable = _parent.source5.subscribe(observer5)Zip+arity.swift:427 sink.disposable = sink.run()Zip+arity.swift:505 subscription1.disposable = _parent.source1.subscribe(observer1)Zip+arity.swift:506 subscription2.disposable = _parent.source2.subscribe(observer2)Zip+arity.swift:507 subscription3.disposable = _parent.source3.subscribe(observer3)Zip+arity.swift:508 subscription4.disposable = _parent.source4.subscribe(observer4)Zip+arity.swift:509 subscription5.disposable = _parent.source5.subscribe(observer5)Zip+arity.swift:510 subscription6.disposable = _parent.source6.subscribe(observer6)Zip+arity.swift:552 sink.disposable = sink.run()Zip+arity.swift:634 subscription1.disposable = _parent.source1.subscribe(observer1)Zip+arity.swift:635 subscription2.disposable = _parent.source2.subscribe(observer2)Zip+arity.swift:636 subscription3.disposable = _parent.source3.subscribe(observer3)Zip+arity.swift:637 subscription4.disposable = _parent.source4.subscribe(observer4)Zip+arity.swift:638 subscription5.disposable = _parent.source5.subscribe(observer5)Zip+arity.swift:639 subscription6.disposable = _parent.source6.subscribe(observer6)Zip+arity.swift:640 subscription7.disposable = _parent.source7.subscribe(observer7)Zip+arity.swift:685 sink.disposable = sink.run()Zip+arity.swift:771 subscription1.disposable = _parent.source1.subscribe(observer1)Zip+arity.swift:772 subscription2.disposable = _parent.source2.subscribe(observer2)Zip+arity.swift:773 subscription3.disposable = _parent.source3.subscribe(observer3)Zip+arity.swift:774 subscription4.disposable = _parent.source4.subscribe(observer4)Zip+arity.swift:775 subscription5.disposable = _parent.source5.subscribe(observer5)Zip+arity.swift:776 subscription6.disposable = _parent.source6.subscribe(observer6)Zip+arity.swift:777 subscription7.disposable = _parent.source7.subscribe(observer7)Zip+arity.swift:778 subscription8.disposable = _parent.source8.subscribe(observer8)Zip+arity.swift:826 sink.disposable = sink.run()Zip+CollectionType.swift:109 _subscriptions[j].disposable = source.subscribe(AnyObserver { event inZip+CollectionType.swift:134 sink.disposable = sink.run()(newValue: Disposable) -> Disposable? { 0056 if _disposableSet { 0057 rxFatalError("oldState.disposable != nil") 0058 } 0059 0060 _disposableSet = true 0061 0062 if _disposed { 0063 return newValue 0064 } 0065 0066 _disposable = newValue 0067 0068 return nil 0069 } 0070 0071 /** 0072 Disposes the underlying disposable. 0073 */ 0074 public func dispose
SingleAssignmentDisposable.swift:51 _setDisposable(newValue)?.dispose()() { 0075 if _disposed { 0076 return 0077 } 0078 _dispose()?.dispose() 0079 } 0080 0081 private func _dispose
AddRef.swift:24 dispose()Amb.swift:87 self.dispose()AnonymousObservable.swift:32 dispose()Buffer.swift:86 dispose()Buffer.swift:90 dispose()Catch.swift:30 _parent.dispose()Catch.swift:61 dispose()Catch.swift:72 dispose()CombineLatest+CollectionType.swift:55 dispose()CombineLatest+CollectionType.swift:66 dispose()CombineLatest+CollectionType.swift:71 dispose()CombineLatest+CollectionType.swift:82 dispose()CombineLatest+CollectionType.swift:85 _subscriptions[atIndex].dispose()CombineLatest.swift:55 dispose()CombineLatest.swift:70 dispose()CombineLatest.swift:77 dispose()CombineLatest.swift:90 dispose()Debug.swift:46 super.dispose()Deferred.swift:28 dispose()Deferred.swift:40 dispose()Deferred.swift:42 dispose()DelaySubscription.swift:27 dispose()DistinctUntilChanged.swift:42 dispose()DistinctUntilChanged.swift:46 dispose()Do.swift:27 dispose()Do.swift:32 dispose()ElementAt.swift:32 self.dispose()ElementAt.swift:39 dispose()ElementAt.swift:45 self.dispose()ElementAt.swift:53 self.dispose()Filter.swift:35 dispose()Filter.swift:39 dispose()Generate.swift:39 self.dispose()Generate.swift:44 self.dispose()Map.swift:33 dispose()Map.swift:37 dispose()Map.swift:40 dispose()Map.swift:70 dispose()Map.swift:74 dispose()Map.swift:77 dispose()Merge.swift:43 _parent.dispose()Merge.swift:54 _parent.dispose()Merge.swift:131 dispose()Merge.swift:135 dispose()Merge.swift:138 _sourceSubscription.dispose()Merge.swift:253 _parent.dispose()Merge.swift:265 _parent.dispose()Merge.swift:311 dispose()Merge.swift:316 dispose()Merge.swift:323 dispose()Merge.swift:326 _sourceSubscription.dispose()Multicast.swift:37 dispose()Multicast.swift:47 dispose()ObserveOn.swift:125 _subscription.dispose()ObserveOnSerialDispatchQueue.swift:51 subscription.dispose()Range.swift:55 self.dispose()Reduce.swift:33 dispose()Reduce.swift:37 dispose()Reduce.swift:43 dispose()Reduce.swift:47 dispose()RefCount.swift:61 dispose()RetryWhen.swift:60 super.dispose()RetryWhen.swift:77 super.dispose()RetryWhen.swift:78 _errorHandlerSubscription.dispose()Sample.swift:46 _parent.dispose()Sample.swift:50 _parent.dispose()Sample.swift:58 _parent.dispose()Sample.swift:104 dispose()Sample.swift:107 _sourceSubscription.dispose()Scan.swift:33 dispose()Scan.swift:37 dispose()Scan.swift:40 dispose()ScheduledItem.swift:37 _disposable.dispose()ShareReplay1.swift:74 _connection?.dispose()ShareReplay1.swift:95 _connection?.dispose()ShareReplay1WhileConnected.swift:67 _connection?.dispose()ShareReplay1WhileConnected.swift:85 _connection?.dispose()SingleAsync.swift:34 dispose()SingleAsync.swift:43 dispose()SingleAsync.swift:48 dispose()SingleAsync.swift:55 dispose()Sink.swift:54 _forward.dispose()Skip.swift:39 self.dispose()Skip.swift:42 self.dispose()Skip.swift:89 self.dispose()Skip.swift:92 self.dispose()SkipUntil.swift:41 _subscription.dispose()SkipUntil.swift:44 _parent.dispose()SkipUntil.swift:46 _subscription.dispose()SkipUntil.swift:90 dispose()SkipUntil.swift:95 _sourceSubscription.dispose()SkipWhile.swift:30 dispose()SkipWhile.swift:40 dispose()SkipWhile.swift:68 dispose()SkipWhile.swift:78 dispose()SubscribeOn.swift:26 self.dispose()Switch.swift:64 dispose()Switch.swift:68 dispose()Switch.swift:72 _subscriptions.dispose()Switch.swift:76 dispose()Switch.swift:123 _parent.dispose()Switch.swift:128 _parent.dispose()TailRecursiveSink.swift:145 super.dispose()Take.swift:38 dispose()Take.swift:43 dispose()Take.swift:46 dispose()Take.swift:100 dispose()Take.swift:103 dispose()Take.swift:111 dispose()TakeLast.swift:35 dispose()TakeLast.swift:41 dispose()TakeUntil.swift:41 _parent.dispose()TakeUntil.swift:44 _parent.dispose()TakeUntil.swift:47 _subscription.dispose()TakeUntil.swift:88 dispose()TakeUntil.swift:91 dispose()TakeWhile.swift:37 dispose()TakeWhile.swift:45 dispose()TakeWhile.swift:49 dispose()TakeWhile.swift:83 dispose()TakeWhile.swift:91 dispose()TakeWhile.swift:95 dispose()Throttle.swift:62 dispose()Throttle.swift:69 dispose()Timeout.swift:69 self.dispose()ToArray.swift:29 self.dispose()ToArray.swift:33 self.dispose()Using.swift:49 dispose()Using.swift:52 dispose()VirtualTimeScheduler.swift:287 self.disposable.dispose()Window.swift:72 dispose()Window.swift:86 dispose()Window.swift:90 dispose()WithLatestFrom.swift:55 dispose()WithLatestFrom.swift:59 dispose()WithLatestFrom.swift:62 dispose()WithLatestFrom.swift:101 _parent.dispose()Zip+CollectionType.swift:55 self.dispose()Zip+CollectionType.swift:79 self.dispose()Zip+CollectionType.swift:84 self.dispose()Zip+CollectionType.swift:95 self.dispose()Zip+CollectionType.swift:98 _subscriptions[atIndex].dispose()Zip.swift:60 dispose()Zip.swift:76 self.dispose()Zip.swift:83 dispose()Zip.swift:100 dispose()() -> Disposable? { 0082 _lock.lock(); defer { _lock.unlock() } 0083 0084 _disposed = true 0085 let disposable = _disposable 0086 _disposable = nil 0087 0088 return disposable 0089 } 0090 } 0091
SingleAssignmentDisposable.swift:78 _dispose()?.dispose()