0001    //
0002    //  Repeat.swift
0003    //  RxExample
0004    //
0005    //  Created by Krunoslav Zaher on 9/13/15.
0006    //  Copyright © 2015 Krunoslav Zaher. All rights reserved.
0007    //
0008    
0009    import Foundation
0010    
0011    class RepeatElement
Observable+Creation.swift:158
        return RepeatElement(element: element, scheduler: scheduler)
Repeat.swift:29
    typealias Parent = RepeatElement<O.E>
<Element
Repeat.swift:11
class RepeatElement<Element> : Producer<Element> {
Repeat.swift:12
    private let _element: Element
Repeat.swift:15
    init(element: Element, scheduler: ImmediateSchedulerType) {
Repeat.swift:20
    override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
> : Producer<Element> {
0012        private let _element
Repeat.swift:16
        _element = element
Repeat.swift:39
        return _parent._scheduler.scheduleRecursive(_parent._element) { e, recurse in
: Element
0013        private let _scheduler
Repeat.swift:17
        _scheduler = scheduler
Repeat.swift:39
        return _parent._scheduler.scheduleRecursive(_parent._element) { e, recurse in
: ImmediateSchedulerType
0014        
0015        init
Observable+Creation.swift:158
        return RepeatElement(element: element, scheduler: scheduler)
(element: Element, scheduler: ImmediateSchedulerType) {
0016            _element = element
0017            _scheduler = scheduler
0018        }
0019        
0020        override func run<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
0021            let sink = RepeatElementSink(parent: self, observer: observer)
0022            sink.disposable = sink.run()
0023    
0024            return sink
0025        }
0026    }
0027    
0028    class RepeatElementSink
Repeat.swift:21
        let sink = RepeatElementSink(parent: self, observer: observer)
<O
Repeat.swift:28
class RepeatElementSink<O: ObserverType> : Sink<O> {
Repeat.swift:29
    typealias Parent = RepeatElement<O.E>
Repeat.swift:33
    init(parent: Parent, observer: O) {
: ObserverType> : Sink<O> {
0029        typealias Parent
Repeat.swift:31
    private let _parent: Parent
Repeat.swift:33
    init(parent: Parent, observer: O) {
 = RepeatElement<O.E>
0030        
0031        private let _parent
Repeat.swift:34
        _parent = parent
Repeat.swift:39
        return _parent._scheduler.scheduleRecursive(_parent._element) { e, recurse in
Repeat.swift:39
        return _parent._scheduler.scheduleRecursive(_parent._element) { e, recurse in
: Parent
0032        
0033        init
Repeat.swift:21
        let sink = RepeatElementSink(parent: self, observer: observer)
(parent: Parent, observer: O) {
0034            _parent = parent
0035            super.init(observer: observer)
0036        }
0037        
0038        func run
Repeat.swift:22
        sink.disposable = sink.run()
() -> Disposable {
0039            return _parent._scheduler.scheduleRecursive(_parent._element) { e, recurse in
0040                self.forwardOn(.Next(e))
0041                recurse(e)
0042            }
0043        }
0044    }