在 Kotlin 中使用 Observable 解析 API 响应

Question

我正在尝试将数据从服务器解析到我的移动设备，为此我正在使用 Rx、Kotlin、retrofit

ApiInterface.kt

@GET("api/v1/admin/class/getUsers/learner/{classId}")
    fun getStudentsRx(
        @Header("access_token") accessToken: String,
        @Path("classId") apiKey: String
    ): Observable<StudentResultResponse>

我尝试订阅如下：

 private fun getServerDataDisposable(dataService: ApiInterface): Disposable {
        return dataService.getStudentsRx(accessToken,classId)
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeWith(object: DisposableSingleObserver<List<StudentModel>>(), Observer<StudentResultResponse> {

                override fun onSuccess(movies: List<StudentModel>) {
                }

                override fun onError(e: Throwable) {

                }

                override fun onChanged(t: StudentResultResponse?) {
                    TODO("not implemented") //To change body of created functions use File | Settings | File Templates.
                }

            })
    }

我遇到错误：

Answer 1

检查下面的答案...

private fun getServerDataDisposable(dataService: ApiInterface): Disposable {
    return dataService.getStudentsRx(accessToken,classId)
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeWith(object: DisposableSingleObserver<StudentResultResponse>(), Observer<StudentResultResponse> {

                override fun onSuccess(t: StudentResultResponse) {
                    TODO("Not yet implemented")
                }

                override fun onError(e: Throwable) {
                    TODO("Not yet implemented")
                }

                override fun onComplete() {
                    TODO("Not yet implemented")
                }

                override fun onNext(t: StudentResultResponse) {
                    TODO("Not yet implemented")
                }

            })
}

在 Kotlin 中使用 Observable 解析 API 响应

Using Observable in Kotlin to parse a API response

android

kotlin

rx-java

rx-kotlin