В настоящее время я пытаюсь заставить RxSwift работать. И я хочу создать пользовательский Observable. Но я думаю, что я делаю что-то неправильно.
Я переделал то, что я делаю с этим минимальным образцом:
import Foundation
import RxSwift
class Example
{
let exampleObservable : Observable<String> = Observable.create { (observer) in
observer.on(.Next("hello"))
observer.on(.Completed)
return AnonymousDisposable { }
}
let exampleObserver : AnyObserver<String>?
func run()
{
self.exampleObserver = exampleObservable.subscribeNext({ (text) -> Void in
print(text)
})
}
}
let ex = Example()
ex.run()
Это правильно? В методе run метод subscribeNext автоматически заполняется XCode.
Но когда я его запускаю, я получаю следующую ошибку компиляции:
Cannot Invoke 'substribeNext' with an argument list of type ((String) -> Void)