您不会将 observable 强制转换为类型，而是订阅该 observables 事件。
func observeSomeData() -> Observable<Data> {
// some rx magic
return Observable.create { observer in
let string = "Hello World"
let data = string.data(using: String.Encoding.utf8)
observer.on(.next(data))
observer.on(.completed)
return Disposables.create()
}
}
您现在订阅了这个 observable 并响应它的事件。您可以通过多种方式做到这一点，我更喜欢更详细的方式。
_ = observeSomeData.subscribe() { event in
switch event {
case .next(let data):
// here you have data.
case .error(let error):
// an error occurred
case .completed:
// the observable has finished sending events.
}
}
RxSwift GitHub 页面上的Getting Started 文档有更多信息。
更新：
我不是 RxSwift 方面的专家，但我相信我已经设法让它发挥作用。
这是我在一个测试项目中拥有的代码的第一个版本。
class ViewController: UIViewController {
override func viewDidLoad() {
super.viewDidLoad()
_ = getData().subscribe() { event in
switch event {
case .next(let data):
let str = String(data: data, encoding: String.Encoding.utf8)
print("Received string data: \(String(describing: str))")
case .completed:
print("completed")
case .error(let error):
print("error occurred: \(error)")
}
}
}
func getData() -> Observable<Data> {
return Observable.create { observer in
let data = "Hello World".data(using: String.Encoding.utf8)!
observer.on(.next(data))
observer.on(.completed)
return Disposables.create()
}
}
}
所以这段代码只是创建了一个 Observable 类型的 observable，它只是发出一个包含一些数据的事件。这有效，但不会按照您的意愿转换数据。
我的第二版代码..
class ViewController: UIViewController {
override func viewDidLoad() {
super.viewDidLoad()
_ = getData().flatMap({ (data: Data) -> Observable<String> in
return Observable.just(String(data: data, encoding: String.Encoding.utf8)!)
}).subscribe() { event in
switch event {
case .next(let str):
print("Received string data: \(String(describing: str))")
case .completed:
print("completed")
case .error(let error):
print("error occurred: \(error)")
}
}
}
func getData() -> Observable<Data> {
return Observable.create { observer in
let data = "Hello World".data(using: String.Encoding.utf8)!
observer.on(.next(data))
observer.on(.completed)
return Disposables.create()
}
}
}
所以在这里，请注意 observable 本身没有改变。现在，当我订阅 observable 时，我使用 flatMap 将传入的数据转换为 Observable 类型的 Observable。
正如我这样向我解释的那样：在 Rx 世界中，.map 期望您返回传递给它的 same 类型，但 flatMap 可用于将元素转换为某种东西别的。 有人可以澄清这一点或更详细地解释吗？
所以，希望能回答您的问题。您可以使用 flatMap 映射可观察对象以进行转换，然后订阅新的可观察对象，这将为您提供转换后的值。
希望对你有帮助