0001    //
0002    //  Disposable.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    Respresents disposable resource.
0013    */
0014    public protocol DisposableAddRef.swift:40     override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Amb.swift:25     private var _cancel: Disposable
Amb.swift:27     init(parent: Parent, cancel: Disposable, sink: Sink) {
Amb.swift:66     func run() -> Disposable {
Amb.swift:75         let decide = { (o: AmbObserverType, event: Event<ElementType>, me: AmbState, otherSubscription: Disposable) in
Amb.swift:117     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
AnonymousObservable.swift:37     func run(parent: Parent) -> Disposable {
AnonymousObservable.swift:43     typealias SubscribeHandler = (AnyObserver<Element>) -> Disposable
AnonymousObservable.swift:51     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
AsyncLock.swift:22     : Disposable
Bag.swift:303 public func disposeAllIn(bag: Bag<Disposable>) {
BehaviorSubject.swift:21     , Disposable {
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 {
BinaryDisposable.swift:19     private var _disposable1: Disposable?
BinaryDisposable.swift:20     private var _disposable2: Disposable?
BinaryDisposable.swift:37     init(_ disposable1: Disposable, _ disposable2: Disposable) {
BinaryDisposable.swift:37     init(_ disposable1: Disposable, _ disposable2: Disposable) {
BooleanDisposable.swift:14 public class BooleanDisposable : Disposable, Cancelable {
Buffer.swift:25     override func run<O : ObserverType where O.E == [Element]>(observer: O) -> Disposable {
Buffer.swift:54     func run() -> Disposable {
Cancelable.swift:14 public protocol Cancelable : Disposable {
Catch.swift:47     func run() -> Disposable {
Catch.swift:89     override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Catch.swift:123     override func subscribeToNext(source: Observable<E>) -> Disposable {
Catch.swift:157     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
CombineLatest+arity.swift:50     func run() -> Disposable {
CombineLatest+arity.swift:86     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:132     func run() -> Disposable {
CombineLatest+arity.swift:174     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:221     func run() -> Disposable {
CombineLatest+arity.swift:269     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:317     func run() -> Disposable {
CombineLatest+arity.swift:371     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:420     func run() -> Disposable {
CombineLatest+arity.swift:480     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:530     func run() -> Disposable {
CombineLatest+arity.swift:596     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+arity.swift:647     func run() -> Disposable {
CombineLatest+arity.swift:719     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest+CollectionType.swift:91     func run() -> Disposable {
CombineLatest+CollectionType.swift:120     override func run<O : ObserverType where O.E == R>(observer: O) -> Disposable {
CombineLatest.swift:106     private let _this: Disposable
CombineLatest.swift:109     init(lock: NSRecursiveLock, parent: CombineLatestProtocol, index: Int, setLatestValue: ValueSetter, this: Disposable) {
CompositeDisposable.swift:14 public class CompositeDisposable : DisposeBase, Disposable, Cancelable {
CompositeDisposable.swift:15     public typealias DisposeKey = Bag<Disposable>.KeyType
CompositeDisposable.swift:20     private var _disposables: Bag<Disposable>? = Bag()
CompositeDisposable.swift:35     public init(_ disposable1: Disposable, _ disposable2: Disposable) {
CompositeDisposable.swift:35     public init(_ disposable1: Disposable, _ disposable2: Disposable) {
CompositeDisposable.swift:43     public init(_ disposable1: Disposable, _ disposable2: Disposable, _ disposable3: Disposable) {
CompositeDisposable.swift:43     public init(_ disposable1: Disposable, _ disposable2: Disposable, _ disposable3: Disposable) {
CompositeDisposable.swift:43     public init(_ disposable1: Disposable, _ disposable2: Disposable, _ disposable3: Disposable) {
CompositeDisposable.swift:52     public init(disposables: [Disposable]) {
CompositeDisposable.swift:65     public func addDisposable(disposable: Disposable) -> DisposeKey? {
CompositeDisposable.swift:75     private func _addDisposable(disposable: Disposable) -> DisposeKey? {
CompositeDisposable.swift:100     private func _removeDisposable(disposeKey: DisposeKey) -> Disposable? {
CompositeDisposable.swift:114     private func _dispose() -> Bag<Disposable>? {
Concat.swift:33     override func subscribeToNext(source: Observable<E>) -> Disposable {
Concat.swift:58     override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
ConcurrentDispatchQueueScheduler.swift:67     public final func schedule<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
ConcurrentDispatchQueueScheduler.swift:67     public final func schedule<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
ConcurrentDispatchQueueScheduler.swift:71     func scheduleInternal<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
ConcurrentDispatchQueueScheduler.swift:71     func scheduleInternal<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
ConcurrentDispatchQueueScheduler.swift:93     public final func scheduleRelative<StateType>(state: StateType, dueTime: NSTimeInterval, action: (StateType) -> Disposable) -> Disposable {
ConcurrentDispatchQueueScheduler.swift:93     public final func scheduleRelative<StateType>(state: StateType, dueTime: NSTimeInterval, action: (StateType) -> Disposable) -> Disposable {
ConcurrentDispatchQueueScheduler.swift:125     public func schedulePeriodic<StateType>(state: StateType, startAfter: TimeInterval, period: TimeInterval, action: (StateType) -> StateType) -> Disposable {
ConcurrentMainScheduler.swift:50     public func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
ConcurrentMainScheduler.swift:50     public func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
ConcurrentMainScheduler.swift:76     public final func scheduleRelative<StateType>(state: StateType, dueTime: NSTimeInterval, action: (StateType) -> Disposable) -> Disposable {
ConcurrentMainScheduler.swift:76     public final func scheduleRelative<StateType>(state: StateType, dueTime: NSTimeInterval, action: (StateType) -> Disposable) -> Disposable {
ConcurrentMainScheduler.swift:89     public func schedulePeriodic<StateType>(state: StateType, startAfter: TimeInterval, period: TimeInterval, action: (StateType) -> StateType) -> Disposable {
ConnectableObservable.swift:23     public func connect() -> Disposable {
ConnectableObservable.swift:28 class Connection<S: SubjectType> : Disposable {
ConnectableObservable.swift:32     private var _subscription : Disposable?
ConnectableObservable.swift:34     init(parent: ConnectableObservableAdapter<S>, subscription: Disposable) {
ConnectableObservable.swift:76     override func connect() -> Disposable {
ConnectableObservable.swift:89     override func subscribe<O : ObserverType where O.E == S.E>(observer: O) -> Disposable {
ConnectableObservableType.swift:20     func connect() -> Disposable
CurrentThreadScheduler.swift:104     public func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
CurrentThreadScheduler.swift:104     public func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
Debug.swift:72     override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Deferred.swift:21     func run() -> Disposable {
Deferred.swift:56     override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
DelaySubscription.swift:44     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
DisposeBag.swift:11 extension Disposable {
DisposeBag.swift:39     private var _disposables = [Disposable]()
DisposeBag.swift:54     public func addDisposable(disposable: Disposable) {
DisposeBag.swift:58     private func _addDisposable(disposable: Disposable) -> Disposable? {
DisposeBag.swift:58     private func _addDisposable(disposable: Disposable) -> Disposable? {
DisposeBag.swift:80     private func _dispose() -> [Disposable] {
DistinctUntilChanged.swift:65     override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
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:55     override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Generate.swift:24     func run() -> Disposable {
Generate.swift:66     override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ImmediateScheduler.swift:28     func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
ImmediateScheduler.swift:28     func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
ImmediateSchedulerType.swift:22     func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable
ImmediateSchedulerType.swift:22     func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable
ImmediateSchedulerType.swift:33     public func scheduleRecursive<State>(state: State, action: (state: State, recurse: (State) -> ()) -> ()) -> Disposable {
Just.swift:21     func run() -> 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 {
MainScheduler.swift:46     override func scheduleInternal<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
MainScheduler.swift:46     override func scheduleInternal<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
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:18     typealias DisposeKey = Bag<Disposable>.KeyType
Merge.swift:88     func run(source: Observable<S>) -> Disposable {
Merge.swift:155     override func run<O: ObserverType where O.E == S.E>(observer: O) -> Disposable {
Merge.swift:341     func run(source: Observable<SourceType>) -> Disposable {
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:23     func run() -> Disposable {
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 {
NopDisposable.swift:16 public struct NopDisposable : Disposable {
NopDisposable.swift:21     public static let instance: Disposable = NopDisposable()
Observable+Creation.swift:23     public static func create(subscribe: (AnyObserver<E>) -> Disposable) -> Observable<E> {
Observable+Creation.swift:171     public static func using<R: Disposable>(resourceFactory: () throws -> R, observableFactory: R throws -> Observable<E>) -> Observable<E> {
Observable+Extensions.swift:20         -> Disposable {
Observable+Extensions.swift:39         -> Disposable {
Observable+Extensions.swift:41         let disposable: Disposable
Observable+Extensions.swift:76         -> Disposable {
Observable+Extensions.swift:93         -> Disposable {
Observable+Extensions.swift:110         -> 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:26     var cachedScheduleLambda: ((ObserveOnSerialDispatchQueueSink<O>, Event<E>) -> Disposable)!
ObserveOnSerialDispatchQueue.swift:69     override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
ObserverBase.swift:11 class ObserverBase<ElementType> : Disposable, ObserverType {
OperationQueueScheduler.swift:35     public func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
OperationQueueScheduler.swift:35     public func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
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:47     func run() -> Disposable {
RecursiveScheduler.swift:42         let d = _scheduler.scheduleRelative(state, dueTime: dueTime) { (state) -> Disposable in
RecursiveScheduler.swift:85         let d = _scheduler.schedule(state) { (state) -> Disposable in
RecursiveScheduler.swift:155         let d = _scheduler.schedule(state) { (state) -> Disposable in
Reduce.swift:69     override func run<O: ObserverType where O.E == ResultType>(observer: O) -> Disposable {
RefCount.swift:24     func run() -> Disposable {
RefCount.swift:71     private var _connectableSubscription = nil as Disposable?
RefCount.swift:79     override func run<O: ObserverType where O.E == CO.E>(observer: O) -> Disposable {
RefCountDisposable.swift:16     private var _disposable = nil as Disposable?
RefCountDisposable.swift:33     public init(disposable: Disposable) {
RefCountDisposable.swift:43     public func retain() -> Disposable {
RefCountDisposable.swift:64         let oldDisposable: Disposable? = _lock.calculateLocked {
RefCountDisposable.swift:85         let oldDisposable: Disposable? = _lock.calculateLocked {
RefCountDisposable.swift:112 internal final class RefCountInnerDisposable: DisposeBase, Disposable
Repeat.swift:20     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Repeat.swift:38     func run() -> Disposable {
ReplaySubject.swift:20     , Disposable {
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:121     override func subscribeToNext(source: Observable<E>) -> Disposable {
RetryWhen.swift:127     override func run(sources: SequenceGenerator) -> Disposable {
RetryWhen.swift:145     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Sample.swift:87     func run() -> Disposable {
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 {
ScheduledDisposable.swift:11 private let disposeScheduledDisposable: ScheduledDisposable -> Disposable = { sd in
ScheduledDisposable.swift:25     private var _disposable: Disposable?
ScheduledDisposable.swift:42     init(scheduler: ImmediateSchedulerType, disposable: Disposable) {
ScheduledItem.swift:14     typealias Action = T -> Disposable
SchedulerServices+Emulation.swift:36     func start() -> Disposable {
SchedulerType.swift:41     func scheduleRelative<StateType>(state: StateType, dueTime: RxTimeInterval, action: (StateType) -> Disposable) -> Disposable
SchedulerType.swift:41     func scheduleRelative<StateType>(state: StateType, dueTime: RxTimeInterval, action: (StateType) -> Disposable) -> Disposable
SchedulerType.swift:52     func schedulePeriodic<StateType>(state: StateType, startAfter: RxTimeInterval, period: RxTimeInterval, action: (StateType) -> StateType) -> Disposable
SchedulerType.swift:65     public func schedulePeriodic<StateType>(state: StateType, startAfter: RxTimeInterval, period: RxTimeInterval, action: (StateType) -> StateType) -> Disposable {
SchedulerType.swift:71     func scheduleRecursive<State>(state: State, dueTime: RxTimeInterval, action: (state: State, scheduler: AnyRecursiveScheduler<State>) -> ()) -> Disposable {
Sequence.swift:21     func run() -> Disposable {
Sequence.swift:43     override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
SerialDispatchQueueScheduler.swift:103     public final func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
SerialDispatchQueueScheduler.swift:103     public final func schedule<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
SerialDispatchQueueScheduler.swift:107     func scheduleInternal<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
SerialDispatchQueueScheduler.swift:107     func scheduleInternal<StateType>(state: StateType, action: (StateType) -> Disposable) -> Disposable {
SerialDispatchQueueScheduler.swift:130     public final func scheduleRelative<StateType>(state: StateType, dueTime: NSTimeInterval, action: (StateType) -> Disposable) -> Disposable {
SerialDispatchQueueScheduler.swift:130     public final func scheduleRelative<StateType>(state: StateType, dueTime: NSTimeInterval, action: (StateType) -> Disposable) -> Disposable {
SerialDispatchQueueScheduler.swift:162     public func schedulePeriodic<StateType>(state: StateType, startAfter: TimeInterval, period: TimeInterval, action: (StateType) -> StateType) -> Disposable {
SerialDisposable.swift:18     private var _current = nil as Disposable?
SerialDisposable.swift:51             let disposable: Disposable? = _lock.calculateLocked {
SerialDisposable.swift:44     public var disposable: Disposable {
SerialDisposable.swift:75     private func _dispose() -> 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 {
SingleAssignmentDisposable.swift:16 public class SingleAssignmentDisposable : DisposeBase, Disposable, Cancelable {
SingleAssignmentDisposable.swift:22     private var _disposable = nil as Disposable?
SingleAssignmentDisposable.swift:45     public var disposable: Disposable {
SingleAssignmentDisposable.swift:55     private func _setDisposable(newValue: Disposable) -> Disposable? {
SingleAssignmentDisposable.swift:55     private func _setDisposable(newValue: Disposable) -> Disposable? {
SingleAssignmentDisposable.swift:81     private func _dispose() -> Disposable? {
SingleAsync.swift:71     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Skip.swift:57     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Skip.swift:100     func run() -> Disposable {
Skip.swift:123     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SkipUntil.swift:99     func run() -> 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 {
StableCompositeDisposable.swift:12     public static func create(disposable1: Disposable, _ disposable2: Disposable) -> Disposable {
StableCompositeDisposable.swift:12     public static func create(disposable1: Disposable, _ disposable2: Disposable) -> Disposable {
StableCompositeDisposable.swift:12     public static func create(disposable1: Disposable, _ disposable2: Disposable) -> Disposable {
StartWith.swift:21     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
SubscribeOn.swift:30     func run() -> Disposable {
SubscribeOn.swift:36         cancelSchedule.disposable = parent.scheduler.schedule(()) { (_) -> Disposable in
SubscribeOn.swift:55     override func run<O : ObserverType where O.E == Ob.E>(observer: O) -> Disposable {
SubscriptionDisposable.swift:11 struct SubscriptionDisposable<T: SynchronizedUnsubscribeType> : Disposable {
Switch.swift:32     func run(source: Observable<SourceType>) -> Disposable {
Switch.swift:91     private let _self: Disposable
Switch.swift:97     init(parent: Parent, id: Int, _self: 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 {
SynchronizedDisposeType.swift:11 protocol SynchronizedDisposeType : class, Disposable, 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 {
TailRecursiveSink.swift:39     func run(sources: SequenceGenerator) -> Disposable {
TailRecursiveSink.swift:135     func subscribeToNext(source: Observable<E>) -> Disposable {
Take.swift:64     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Take.swift:114     func run() -> 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:95     func run() -> 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:35     func run() -> Disposable {
Throttle.swift:73     func propagate(currentId: UInt64) -> Disposable {
Throttle.swift:98     override func run<O: ObserverType where O.E == Element>(observer: O) -> Disposable {
Timeout.swift:30     func run() -> Disposable {
Timeout.swift:115     override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
Timer.swift:21     func run() -> Disposable {
Timer.swift:39     func run() -> Disposable {
Timer.swift:40         return _parent._scheduler.scheduleRelative((), dueTime: _parent._dueTime) { (_) -> Disposable in
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:23     func run() -> Disposable {
Using.swift:73     override func run<O : ObserverType where O.E == E>(observer: O) -> Disposable {
VirtualTimeScheduler.swift:75     public func schedule<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:75     public func schedule<StateType>(state: StateType, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:89     public func scheduleRelative<StateType>(state: StateType, dueTime: RxTimeInterval, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:89     public func scheduleRelative<StateType>(state: StateType, dueTime: RxTimeInterval, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:104     public func scheduleRelativeVirtual<StateType>(state: StateType, dueTime: VirtualTimeInterval, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:104     public func scheduleRelativeVirtual<StateType>(state: StateType, dueTime: VirtualTimeInterval, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:117     public func scheduleAbsoluteVirtual<StateType>(state: StateType, time: Converter.VirtualTimeUnit, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:117     public func scheduleAbsoluteVirtual<StateType>(state: StateType, time: Converter.VirtualTimeUnit, action: StateType -> Disposable) -> Disposable {
VirtualTimeScheduler.swift:261     : Disposable {
VirtualTimeScheduler.swift:262     typealias Action = () -> Disposable
Window.swift:40     func run() -> Disposable {
Window.swift:147     override func run<O : ObserverType where O.E == Observable<Element>>(observer: O) -> Disposable {
WithLatestFrom.swift:31     func run() -> Disposable {
WithLatestFrom.swift:76     private let _disposable: Disposable
WithLatestFrom.swift:84     init(parent: Parent, disposable: Disposable) {
WithLatestFrom.swift:119     override func run<O : ObserverType where O.E == ResultType>(observer: O) -> Disposable {
Zip+arity.swift:62     func run() -> Disposable {
Zip+arity.swift:98     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:157     func run() -> Disposable {
Zip+arity.swift:199     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:260     func run() -> Disposable {
Zip+arity.swift:308     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:371     func run() -> Disposable {
Zip+arity.swift:425     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:490     func run() -> Disposable {
Zip+arity.swift:550     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:617     func run() -> Disposable {
Zip+arity.swift:683     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+arity.swift:752     func run() -> Disposable {
Zip+arity.swift:824     override func run<O: ObserverType where O.E == R>(observer: O) -> Disposable {
Zip+CollectionType.swift:104     func run() -> Disposable {
Zip+CollectionType.swift:132     override func run<O : ObserverType where O.E == R>(observer: O) -> Disposable {
Zip.swift:118     private let _this: Disposable
Zip.swift:121     init(lock: NSRecursiveLock, parent: ZipSinkProtocol, index: Int, setNextValue: ValueSetter, this: Disposable) { {
0015        /**
0016        Dispose resource.
0017        */
0018        func disposeAmb.swift:40             _cancel.dispose()
Amb.swift:81                     otherSubscription.dispose()
Bag.swift:305         bag._value0?.dispose()
Bag.swift:315         value0.dispose()
Bag.swift:319         value1.dispose()
Bag.swift:323         pairs[i].value.dispose()
Bag.swift:328             element.dispose()
BinaryDisposable.swift:50             _disposable1?.dispose()
BinaryDisposable.swift:51             _disposable2?.dispose()
CombineLatest.swift:127             _this.dispose()
CombineLatest.swift:130             _this.dispose()
CompositeDisposable.swift:69             disposable.dispose()
CompositeDisposable.swift:97         _removeDisposable(disposeKey)?.dispose()
ConnectableObservable.swift:53             oldSubscription.dispose()
DisposeBag.swift:55         _addDisposable(disposable)?.dispose()
DisposeBag.swift:76             disposable.dispose()
Observable+Extensions.swift:56                 disposable.dispose()
Observable+Extensions.swift:59                 disposable.dispose()
RefCount.swift:38             subscription.dispose()
RefCount.swift:41                     self._parent._connectableSubscription!.dispose()
RefCountDisposable.swift:80             disposable.dispose()
RefCountDisposable.swift:107             disposable.dispose()
ScheduledDisposable.swift:56             _disposable!.dispose()
SerialDisposable.swift:63                 disposable.dispose()
SerialDisposable.swift:72         _dispose()?.dispose()
SingleAssignmentDisposable.swift:51             _setDisposable(newValue)?.dispose()
SingleAssignmentDisposable.swift:78         _dispose()?.dispose()
Switch.swift:111             _self.dispose()
WithLatestFrom.swift:98             _disposable.dispose()
Zip.swift:139                 _this.dispose()
Zip.swift:141                 _this.dispose()()
0019    }
Amb.swift:40	_cancel.dispose()
Amb.swift:81	otherSubscription.dispose()
Bag.swift:305	bag._value0?.dispose()
Bag.swift:315	value0.dispose()
Bag.swift:319	value1.dispose()
Bag.swift:323	pairs[i].value.dispose()
Bag.swift:328	element.dispose()
BinaryDisposable.swift:50	_disposable1?.dispose()
BinaryDisposable.swift:51	_disposable2?.dispose()
CombineLatest.swift:127	_this.dispose()
CombineLatest.swift:130	_this.dispose()
CompositeDisposable.swift:69	disposable.dispose()
CompositeDisposable.swift:97	_removeDisposable(disposeKey)?.dispose()
ConnectableObservable.swift:53	oldSubscription.dispose()
DisposeBag.swift:55	_addDisposable(disposable)?.dispose()
DisposeBag.swift:76	disposable.dispose()
Observable+Extensions.swift:56	disposable.dispose()
Observable+Extensions.swift:59	disposable.dispose()
RefCount.swift:38	subscription.dispose()
RefCount.swift:41	self._parent._connectableSubscription!.dispose()
RefCountDisposable.swift:80	disposable.dispose()
RefCountDisposable.swift:107	disposable.dispose()
ScheduledDisposable.swift:56	_disposable!.dispose()
SerialDisposable.swift:63	disposable.dispose()
SerialDisposable.swift:72	_dispose()?.dispose()
SingleAssignmentDisposable.swift:51	_setDisposable(newValue)?.dispose()
SingleAssignmentDisposable.swift:78	_dispose()?.dispose()
Switch.swift:111	_self.dispose()
WithLatestFrom.swift:98	_disposable.dispose()
Zip.swift:139	_this.dispose()
Zip.swift:141	_this.dispose()