swift – 在一个可观察物内处理一次性物品的正确方法

我有一个HTTPService,它返回一个Observable< NSData>.我的目标是将该服务组合到另一个服务中,ServiceA为我的用例转换该数据.在ServiceA中使用Rx Swift 2.0.0-rc.0中的Observable.create就足够了.我的问题是如何正确处理从HTTPService订阅返回的一次性.

如果我什么都不做,我得到编译时间警告,调用结果未使用：http://git.io/rxs.ud.我从阅读中理解,如果我什么也不做,那可能没问题:(下面提到的xs是让xs：Observable< E&gt ;. ...

In case xs terminates in a predictable way with Completed or Error message,not handling subscription Disposable won’t leak any resources,but it’s still preferred way because in that way element computation is terminated at predictable moment.

所以这就是我目前正在解决的问题,也是我想知道我是否正确地做到这一点,或者我是否误解了一些问题.

public struct ServiceA{

    public static func changes() -> Observable<ChangeSet>{
        return Observable.create{ observable in

            // return's Observable<NSData>
            let request = HTTPService.get("https://httpbin.org/get")

            let disposable = request.subscribe(
                onNext: { data in
                    // Do more work to transform this data
                    // into something meaningful for the application.
                    // For example purposes just use an empty object
                    observable.onNext(ChangeSet())
                    observable.onCompleted()
                },onError:{ error in
                    observable.onError(error)
                })

            // Is this the right way to deal with the
            // disposable from the subscription in this situation?
            return AnonymousDisposable{
                disposable.dispose()
            }
        }
    }
}

public static func changes() -> Observable<ChangeSet>{
        return Observable.create{ observable in

            // return's Observable<NSData>
            let request = HTTPService.get("https://httpbin.org/get")

            return request.subscribe(
                onNext: { data in
                    // Do more work to transform this data
                    // into something meaningful for the application.
                    // For example purposes just use an empty object
                    observable.onNext(ChangeSet())
                    observable.onCompleted()
                },onError:{ error in
                    observable.onError(error)
                    })
}

public static func changes() -> Observable<ChangeSet> {
    return HTTPService.get("https://httpbin.org/get")
                      .map(ChangeSet.init)
}