Получите снимок данных Firebase с помощью rxjava2 - PullRequest
Новая
       9

Получите снимок данных Firebase с помощью rxjava2

0 голосов
/ 16 февраля 2019

Я пытаюсь получить оценку пользователя из базы данных Firebase с помощью RxJava2.Я не получаю никакой ошибки, logcat ясно.Не работает какой-либо метод подписчика (не отображается текст в logcat). 

override fun getUserScore(){
        val query = scoreReference.child(FirebaseAuth.getInstance().currentUser!!.uid)

        rxfirebase(query).subscribeOn(Schedulers.io()).subscribe { object: Subscriber<DataSnapshot>{
            override fun onComplete() {
                Log.d("UserScoreComplete", "complete")
            }

            override fun onSubscribe(s: Subscription?) {
                Log.d("UserScoreSubscribe", "subscribe")
            }

            override fun onNext(t: DataSnapshot?) {
                val score = t?.getValue(Score::class.java)
                Log.d("UserScore", score?.score)
            }

            override fun onError(t: Throwable?) {
                Log.d("UserScoreError", t.toString())
            }
        } }
        }


    override fun rxfirebase(ref: Query): Observable<DataSnapshot>{
        return Observable.create { emitter ->
            ref.addListenerForSingleValueEvent(object: ValueEventListener {
                override fun onCancelled(p0: DatabaseError) {
                    Log.d("rxFirebase error", p0.message)
                    emitter.onError(p0.toException())
                }

                override fun onDataChange(p0: DataSnapshot) {
                    emitter.onNext(p0)
                    emitter.onComplete()
...