0001    //
0002    //  Producer.swift
0003    //  Rx
0004    //
0005    //  Created by Krunoslav Zaher on 2/20/15.
0006    //  Copyright © 2015 Krunoslav Zaher. All rights reserved.
0007    //
0008    
0009    import Foundation
0010    
0011    class Producer
AddRef.swift:29
class AddRef<Element> : Producer<Element> {
Amb.swift:108
class Amb<Element>: Producer<Element> {
AnonymousObservable.swift:42
class AnonymousObservable<Element> : Producer<Element> {
Buffer.swift:11
class BufferTimeCount<Element> : Producer<[Element]> {
Catch.swift:78
class Catch<Element> : Producer<Element> {
Catch.swift:148
class CatchSequence<S: SequenceType where S.Generator.Element : ObservableConvertibleType> : Producer<S.Generator.Element.E> {
CombineLatest+arity.swift:71
class CombineLatest2<E1, E2, R> : Producer<R> {
CombineLatest+arity.swift:157
class CombineLatest3<E1, E2, E3, R> : Producer<R> {
CombineLatest+arity.swift:250
class CombineLatest4<E1, E2, E3, E4, R> : Producer<R> {
CombineLatest+arity.swift:350
class CombineLatest5<E1, E2, E3, E4, E5, R> : Producer<R> {
CombineLatest+arity.swift:457
class CombineLatest6<E1, E2, E3, E4, E5, E6, R> : Producer<R> {
CombineLatest+arity.swift:571
class CombineLatest7<E1, E2, E3, E4, E5, E6, E7, R> : Producer<R> {
CombineLatest+arity.swift:692
class CombineLatest8<E1, E2, E3, E4, E5, E6, E7, E8, R> : Producer<R> {
CombineLatest+CollectionType.swift:107
class CombineLatestCollectionType<C: CollectionType, R where C.Generator.Element : ObservableConvertibleType> : Producer<R> {
Concat.swift:47
class Concat<S: SequenceType where S.Generator.Element : ObservableConvertibleType> : Producer<S.Generator.Element.E> {
Debug.swift:50
class Debug<Element> : Producer<Element> {
Deferred.swift:47
class Deferred<S: ObservableType> : Producer<S.E> {
DelaySubscription.swift:33
class DelaySubscription<Element>: Producer<Element> {
DistinctUntilChanged.swift:51
class DistinctUntilChanged<Element, Key>: Producer<Element> {
Do.swift:37
class Do<Element> : Producer<Element> {
ElementAt.swift:58
class ElementAt<SourceType> : Producer<SourceType> {
Empty.swift:11
class Empty<Element> : Producer<Element> {
Error.swift:11
class Error<Element> : Producer<Element> {
Filter.swift:44
class Filter<Element> : Producer<Element> {
Generate.swift:50
class Generate<S, E> : Producer<E> {
Just.swift:33
class JustScheduled<Element> : Producer<Element> {
Just.swift:49
class Just<Element> : Producer<Element> {
Map.swift:82
class MapWithIndex<SourceType, ResultType> : Producer<ResultType> {
Map.swift:105
class Map<SourceType, ResultType>: Producer<ResultType> {
Merge.swift:146
class MergeLimited<S: ObservableConvertibleType> : Producer<S.E> {
Merge.swift:353
final class FlatMap<SourceType, S: ObservableConvertibleType>: Producer<S.E> {
Merge.swift:372
final class FlatMapWithIndex<SourceType, S: ObservableConvertibleType>: Producer<S.E> {
Merge.swift:392
final class FlatMapFirst<SourceType, S: ObservableConvertibleType>: Producer<S.E> {
Merge.swift:411
final class Merge<S: ObservableConvertibleType> : Producer<S.E> {
Multicast.swift:52
class Multicast<S: SubjectType, R>: Producer<R> {
Never.swift:11
class Never<Element> : Producer<Element> {
ObserveOn.swift:11
class ObserveOn<E> : Producer<E> {
ObserveOnSerialDispatchQueue.swift:55
class ObserveOnSerialDispatchQueue<E> : Producer<E> {
Range.swift:11
class RangeProducer<E: SignedIntegerType> : Producer<E> {
Reduce.swift:53
class Reduce<SourceType, AccumulateType, ResultType> : Producer<ResultType> {
RefCount.swift:66
class RefCount<CO: ConnectableObservableType>: Producer<CO.E> {
Repeat.swift:11
class RepeatElement<Element> : Producer<Element> {
RetryWhen.swift:134
class RetryWhenSequence<S: SequenceType, TriggerObservable: ObservableType, Error where S.Generator.Element : ObservableType> : Producer<S.Generator.Element.E> {
Sample.swift:113
class Sample<Element, SampleType> : Producer<Element> {
Scan.swift:46
class Scan<Element, Accumulate>: Producer<Accumulate> {
Sequence.swift:34
class Sequence<E> : Producer<E> {
SingleAsync.swift:60
class SingleAsync<Element>: Producer<Element> {
Skip.swift:48
class SkipCount<Element>: Producer<Element> {
Skip.swift:112
class SkipTime<Element>: Producer<Element> {
SkipUntil.swift:110
class SkipUntil<Element, Other>: Producer<Element> {
SkipWhile.swift:83
class SkipWhile<Element>: Producer<Element> {
StartWith.swift:11
class StartWith<Element>: Producer<Element> {
SubscribeOn.swift:46
class SubscribeOn<Ob: ObservableType> : Producer<Ob.E> {
Switch.swift:163
final class Switch<S: ObservableConvertibleType> : Producer<S.E> {
Switch.swift:177
final class FlatMapLatest<SourceType, S: ObservableConvertibleType> : Producer<S.E> {
Take.swift:52
class TakeCount<Element>: Producer<Element> {
Take.swift:126
class TakeTime<Element> : Producer<Element> {
TakeLast.swift:46
class TakeLast<Element>: Producer<Element> {
TakeUntil.swift:105
class TakeUntil<Element, Other>: Producer<Element> {
TakeWhile.swift:101
class TakeWhile<Element>: Producer<Element> {
Throttle.swift:86
class Throttle<Element> : Producer<Element> {
Timeout.swift:101
class Timeout<Element> : Producer<Element> {
Timer.swift:49
class Timer<E: SignedIntegerType>: Producer<E> {
ToArray.swift:38
class ToArray<SourceType> : Producer<[SourceType]> {
Using.swift:57
class Using<SourceType, ResourceType: Disposable>: Producer<SourceType> {
Window.swift:133
class WindowTimeCount<Element> : Producer<Observable<Element>> {
WithLatestFrom.swift:106
class WithLatestFrom<FirstType, SecondType, ResultType>: Producer<ResultType> {
Zip+arity.swift:83
class Zip2<E1, E2, R> : Producer<R> {
Zip+arity.swift:182
class Zip3<E1, E2, E3, R> : Producer<R> {
Zip+arity.swift:289
class Zip4<E1, E2, E3, E4, R> : Producer<R> {
Zip+arity.swift:404
class Zip5<E1, E2, E3, E4, E5, R> : Producer<R> {
Zip+arity.swift:527
class Zip6<E1, E2, E3, E4, E5, E6, R> : Producer<R> {
Zip+arity.swift:658
class Zip7<E1, E2, E3, E4, E5, E6, E7, R> : Producer<R> {
Zip+arity.swift:797
class Zip8<E1, E2, E3, E4, E5, E6, E7, E8, R> : Producer<R> {
Zip+CollectionType.swift:119
class ZipCollectionType<C: CollectionType, R where C.Generator.Element : ObservableConvertibleType> : Producer<R> {
<Element
Producer.swift:11
class Producer<Element> : Observable<Element> {
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 {
> : Observable<Element> {
0012        override init
Generate.swift:63
        super.init()
StartWith.swift:18
        super.init()
() {
0013            super.init()
0014        }
0015        
0016        override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
0017            if !CurrentThreadScheduler.isScheduleRequired {
0018                return run(observer)
0019            }
0020            else {
0021                return CurrentThreadScheduler.instance.schedule(()) { _ in
0022                    return self.run(observer)
0023                }
0024            }
0025        }
0026        
0027        func run
Producer.swift:18
            return run(observer)
Producer.swift:22
                return self.run(observer)
<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
0028            abstractMethod()
0029        }
0030    }