ドメインイベントをObservableに変換

query.swift

import Foundation
import RxSwift
import SwiftEventBus

class Query {
    static func query() -> Observable<String> {
        return Observable.create { observer in
            SwiftEventBus.onMainThread(self, name: "SomeDomainEvent") { result in
                observer.on(.Next("SomeDomainEvent"))
            }

            return AnonymousDisposable {
                SwiftEventBus.unregister("SomeDomainEvent")
            }
        }
    }
}