RxSwift技术咨询：如何获取函数非可观察值及修复异步返回问题

首先，你的函数出问题的核心原因是网络请求是异步操作——subscribe里的onNext/onError闭包要等网络请求完成后才会执行，但你的函数在调用networkRequest.subscribe()之后立刻就返回了data。这时候不仅data还没被异步回调赋值，甚至因为你只声明了var data: String却没初始化，连编译都通不过。

修复函数：返回Observable而非同步值 #

RxSwift的设计核心就是用Observable封装异步数据流，正确的做法是让函数返回Observable<String>，把网络请求的结果通过流传递出去，而不是试图同步返回结果。修改后的代码如下：

func fetchedData() -> Observable<String> {
    return networkRequest
        .map { _ in "successful" } // 请求成功时映射为指定字符串
        .catch { _ in Observable.just("unsuccessful") } // 请求失败时返回对应错误字符串
}

之后在调用这个函数的地方，通过subscribe来接收异步结果：

fetchedData()
    .subscribe(onNext: { result in
        print("请求结果：\(result)")
        // 在这里处理拿到的结果，比如更新UI、保存数据等
    })
    .disposed(by: disposeBag)

这种写法完全贴合RxSwift的异步流处理逻辑，从根源上解决了时序问题。

关于“从函数中获取非可观察值”的疑问 #

首先要明确：异步操作不应该强行同步获取结果，这会阻塞线程（比如在主线程这么做会导致UI卡顿甚至无响应），违背了RxSwift异步处理的初衷。

但如果确实有特殊场景需要同步获取结果（比如测试代码、后台线程的同步任务），可以使用RxSwift的BlockingObservable，示例如下：

do {
    let result = try fetchedData().toBlocking().first()!
    print("同步获取的结果：\(result)")
} catch {
    print("同步获取失败：\(error)")
}

⚠️ 注意：这种方式会阻塞当前线程直到请求完成，绝对不要在主线程调用，否则会严重影响App的响应性。

内容的提问来源于stack exchange，提问作者Ozx