Tag: Facebook图形API

当链接从Observable.create（）创建的Observable时，RxJava用户onNext / onError / onComplete没有被调用

我试图实现一个基本的RxJava链接调用 从Facebook Graph API获取用户名和照片 使用该信息然后注册我的后端服务 所以我尝试使用下面的flatMap getProfileFromFacebook().flatMap { user -> userRepository.createUser(user) } .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( { Log.d("test", "onNext") }, { Log.d("test", "onError") }, { Log.d("test", "onComplete") }) 奇怪的是，没有任何用户的记录打印出来。 所以我试图用Observable.just（User（））替换getProfleFromFacebook（）。 这一次工作，onNext打印出来。 所以我想这个问题是在getProfleFromFacebook（）。 这是它的实现 fun getProfileFromFacebook(): Observable<User> { return Observable.create<User>({ emitter -> val request = GraphRequest.newMeRequest(AccessToken.getCurrentAccessToken()) { _, _ -> emitter.onNext(User()) emitter.onCompleted() } val parameters = Bundle() […]