2016-07-21 20:28:58 +03:00
|
|
|
/**
|
|
|
|
* Tae Won Ha - http://taewon.de - @hataewon
|
|
|
|
* See LICENSE
|
|
|
|
*/
|
|
|
|
|
2016-08-03 22:41:43 +03:00
|
|
|
import Cocoa
|
2016-07-21 20:28:58 +03:00
|
|
|
import RxSwift
|
|
|
|
|
2016-07-26 22:42:30 +03:00
|
|
|
protocol Flow {
|
2016-08-30 23:25:34 +03:00
|
|
|
|
2016-07-21 20:28:58 +03:00
|
|
|
var sink: Observable<Any> { get }
|
|
|
|
}
|
|
|
|
|
2016-07-26 22:42:30 +03:00
|
|
|
protocol Store: Flow {}
|
|
|
|
|
|
|
|
protocol Component: Flow {}
|
|
|
|
|
2016-08-30 23:25:34 +03:00
|
|
|
class StandardFlow: Flow {
|
|
|
|
|
|
|
|
var sink: Observable<Any> {
|
|
|
|
return self.subject.asObservable()
|
|
|
|
}
|
|
|
|
|
|
|
|
let subject = PublishSubject<Any>()
|
|
|
|
let source: Observable<Any>
|
|
|
|
let disposeBag = DisposeBag()
|
|
|
|
|
|
|
|
init(source: Observable<Any>) {
|
|
|
|
self.source = source
|
|
|
|
self.subscription(source: source).addDisposableTo(self.disposeBag)
|
|
|
|
}
|
|
|
|
|
|
|
|
deinit {
|
|
|
|
self.subject.onCompleted()
|
|
|
|
}
|
|
|
|
|
|
|
|
func subscription(source source: Observable<Any>) -> Disposable {
|
|
|
|
preconditionFailure("Please override")
|
|
|
|
}
|
|
|
|
|
|
|
|
func publish(event event: Any) {
|
|
|
|
self.subject.onNext(event)
|
|
|
|
}
|
2016-07-21 20:28:58 +03:00
|
|
|
}
|
2016-08-30 23:25:34 +03:00
|
|
|
|
|
|
|
class StandardComponent: NSObject, Component {
|
|
|
|
|
|
|
|
var sink: Observable<Any> {
|
|
|
|
return self.subject.asObservable()
|
|
|
|
}
|
|
|
|
|
|
|
|
let subject = PublishSubject<Any>()
|
|
|
|
let source: Observable<Any>
|
|
|
|
let disposeBag = DisposeBag()
|
|
|
|
|
|
|
|
init(source: Observable<Any>) {
|
|
|
|
self.source = source
|
|
|
|
super.init()
|
|
|
|
|
|
|
|
self.addViews()
|
|
|
|
self.subscription(source: source).addDisposableTo(self.disposeBag)
|
|
|
|
}
|
|
|
|
|
|
|
|
deinit {
|
|
|
|
self.subject.onCompleted()
|
|
|
|
}
|
|
|
|
|
|
|
|
func addViews() {
|
|
|
|
preconditionFailure("Please override")
|
|
|
|
}
|
|
|
|
|
|
|
|
func subscription(source source: Observable<Any>) -> Disposable {
|
|
|
|
preconditionFailure("Please override")
|
|
|
|
}
|
|
|
|
|
|
|
|
func publish(event event: Any) {
|
|
|
|
self.subject.onNext(event)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
class WindowComponent: StandardComponent {
|
|
|
|
|
|
|
|
let windowController: NSWindowController
|
|
|
|
var window: NSWindow {
|
|
|
|
return self.windowController.window!
|
|
|
|
}
|
|
|
|
|
|
|
|
init(source: Observable<Any>, nibName: String) {
|
|
|
|
self.windowController = NSWindowController(windowNibName: nibName)
|
|
|
|
super.init(source: source)
|
|
|
|
}
|
|
|
|
|
|
|
|
func show() {
|
|
|
|
self.windowController.showWindow(self)
|
|
|
|
}
|
|
|
|
}
|