android - 使用 Android/Firebase 实时数据库时，Single.Create()...blockingGet() 在 RxJava 2.1.3 中挂起

Question

当使用以下模式从 Firebase 实时数据库同步获取数据时:

String s = Single.create(new SingleOnSubscribe<String>() {
    @Override
    public void subscribe(SingleEmitter<String> e) throws Exception {
    FirebaseDatabase.getInstance().getReference("path").orderByChild("child").equalTo("xyz").addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
        e.onSuccess("Got it");
        }
        @Override
        public void onCancelled(DatabaseError databaseError) {
        e.onError(databaseError.toException());
        }
    });
}
}).blockingGet();

它将挂起并产生 ANR 错误。如果我在 Single 之外使用相同的 Firebase“内部结构”，它就会正常运行。里面没有 Firebase 代码的 Single 也会触发，所以看起来两者之间有些不兼容。

有什么想法吗？

Answer 1

Firebase 在 ui 线程上传递事件，等待结果与 blockingGet 死锁。在我看来，您应该重新考虑应用程序逻辑并使用 subscribe(SingleObserver)

进行订阅而不阻塞