0001    //
0002    //  Just.swift
0003    //  Rx
0004    //
0005    //  Created by Krunoslav Zaher on 8/30/15.
0006    //  Copyright © 2015 Krunoslav Zaher. All rights reserved.
0007    //
0008    
0009    import Foundation
0010    
0011    class JustScheduledSink
Just.swift:43
        let sink = JustScheduledSink(parent: self, observer: observer)
<O
Just.swift:11
class JustScheduledSink<O: ObserverType> : Sink<O> {
Just.swift:12
    typealias Parent = JustScheduled<O.E>
Just.swift:16
    init(parent: Parent, observer: O) {
: ObserverType> : Sink<O> {
0012        typealias Parent
Just.swift:14
    private let _parent: Parent
Just.swift:16
    init(parent: Parent, observer: O) {
 = JustScheduled<O.E>
0013    
0014        private let _parent
Just.swift:17
        _parent = parent
Just.swift:22
        let scheduler = _parent._scheduler
Just.swift:23
        return scheduler.schedule(_parent._element) { element in
: Parent
0015    
0016        init
Just.swift:43
        let sink = JustScheduledSink(parent: self, observer: observer)
(parent: Parent, observer: O) {
0017            _parent = parent
0018            super.init(observer: observer)
0019        }
0020    
0021        func run
Just.swift:44
        sink.disposable = sink.run()
() -> Disposable {
0022            let scheduler = _parent._scheduler
0023            return scheduler.schedule(_parent._element) { element in
0024                self.forwardOn(.Next(element))
0025                return scheduler.schedule(()) { _ in
0026                    self.forwardOn(.Completed)
0027                    return NopDisposable.instance
0028                }
0029            }
0030        }
0031    }
0032    
0033    class JustScheduled
Just.swift:12
    typealias Parent = JustScheduled<O.E>
Observable+Creation.swift:81
        return JustScheduled(element: element, scheduler: scheduler)
<Element
Just.swift:33
class JustScheduled<Element> : Producer<Element> {
Just.swift:35
    private let _element: Element
Just.swift:37
    init(element: Element, scheduler: ImmediateSchedulerType) {
> : Producer<Element> {
0034        private let _scheduler
Just.swift:22
        let scheduler = _parent._scheduler
Just.swift:38
        _scheduler = scheduler
: ImmediateSchedulerType
0035        private let _element
Just.swift:23
        return scheduler.schedule(_parent._element) { element in
Just.swift:39
        _element = element
: Element
0036    
0037        init
Observable+Creation.swift:81
        return JustScheduled(element: element, scheduler: scheduler)
(element: Element, scheduler: ImmediateSchedulerType) {
0038            _scheduler = scheduler
0039            _element = element
0040        }
0041    
0042        override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
0043            let sink = JustScheduledSink(parent: self, observer: observer)
0044            sink.disposable = sink.run()
0045            return sink
0046        }
0047    }
0048    
0049    class Just
Observable+Creation.swift:67
        return Just(element: element)
<Element
Just.swift:49
class Just<Element> : Producer<Element> {
Just.swift:50
    private let _element: Element
Just.swift:52
    init(element: Element) {
Just.swift:56
    override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
> : Producer<Element> {
0050        private let _element
Just.swift:53
        _element = element
Just.swift:57
        observer.on(.Next(_element))
: Element
0051        
0052        init
Observable+Creation.swift:67
        return Just(element: element)
(element: Element) {
0053            _element = element
0054        }
0055        
0056        override func subscribe<O : ObserverType where O.E == Element>(observer: O) -> Disposable {
0057            observer.on(.Next(_element))
0058            observer.on(.Completed)
0059            return NopDisposable.instance
0060        }
0061    }