如何使用RxJava 2提高从Firebase数据库读取Flowable<Object>数据的性能？

implementation 'io.reactivex.rxjava2:rxjava:2.x.x'
implementation 'io.reactivex.rxjava2:rxandroid:2.x.x'

FirebaseDatabase database = FirebaseDatabase.getInstance();
DatabaseReference reference = database.getReference("your_reference");

reference.addValueEventListener(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        // 将数据转换为Flowable<Object>类型
        Flowable<Object> flowable = Flowable.fromIterable(dataSnapshot.getChildren())
                .map(DataSnapshot::getValue);
        
        // 在这里可以对数据进行进一步的处理
        // ...
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        // 数据读取取消时的处理
    }
});

flowable
    .observeOn(Schedulers.io()) // 指定观察者所在的线程
    .subscribeOn(Schedulers.io()) // 指定数据源所在的线程
    .subscribe(new Consumer<Object>() {
        @Override
        public void accept(Object data) throws Exception {
            // 处理每个数据项
        }
    });