android - RxJava and Firebase database -


i'm trying refactor synchronization procedure rxjava support. i've faced strange (for me) error.

initially, execute 'sync' procedure. in 'oncompleted' execute syncpart2. it's same procedure (but others nodes sync)

in 'syncpart2' 'error=databaseerror: permission denied'. database rules ok, error appears on different nodes (and current sync works fine).

basically, have 16 nodes sync 1 one, in specific order. maybe i've chosen wrong rx operation that? way, if use 1 'concat' ok! have more 9 (max size of 'concat' args) nodes sync. 

public class rxfirebasedatabase {      @nonnull     public static observable<datasnapshot> observesinglevalueevent(@nonnull final query query) {         return observable.create(new observable.onsubscribe<datasnapshot>() {             @override             public void call(final subscriber<? super datasnapshot> subscriber) {                 query.addlistenerforsinglevalueevent(new valueeventlistener() {                     @override                     public void ondatachange(datasnapshot datasnapshot) {                         if (!subscriber.isunsubscribed()) {                             subscriber.onnext(datasnapshot);                             subscriber.oncompleted();                         }                     }                      @override                     public void oncancelled(databaseerror error) {                         if (!subscriber.isunsubscribed()) {                             subscriber.onerror(new rxfirebasedataexception(error));                         }                     }                 });             }         });     }  }     public static void sync() {          observable.concat(                  rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.deleted_objects_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.msi_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.courses_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.allergies_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.phones_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.medicines_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.profiles_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.analyses_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.diagnoses_node))          )                 .observeon(schedulers.io())                 .subscribe(new subscriber<datasnapshot>() {                     @override                     public void oncompleted() {                          syncpart2();                      }                      @override                     public void onerror(throwable e) {                          log.d(appconstants.tag_sync, "the error appears: " + e.getmessage());                      }                      @override                     public void onnext(datasnapshot datasnapshot) {                          genericclass genericclass = retrieveinfoaboutnode(datasnapshot);                          if (genericclass.getmytype() == deletedobject.class) {                              handledeletedobjects(datasnapshot);                          } else if (genericclass.getmytype() == medicinescheduleritem.class) {                              handlemsi(datasnapshot);                          } else if (genericclass.getmytype() == medicinecourse.class) {                              handlemedicinecourse(datasnapshot);                          } else {                              handle(datasnapshot, genericclass);                          }                      }                 });     }      public static void syncpart2() {          observable.concat(                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.hospitals_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.recommendations_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.user_files_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.specializations_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.doctors_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.doctor_visits_node)),                 rxfirebasedatabase.observesinglevalueevent(getfirebasereference(appconstants.firebase_constants.photos_node))         )                 .subscribe(new subscriber<datasnapshot>() {                     @override                     public void oncompleted() {                          eventbus.getdefault().post(new firebaseevents().new syncfinished().new alltasksfinished());                      }                      @override                     public void onerror(throwable e) {                          log.d(appconstants.tag_sync, "the error appears: " + e.getmessage());                      }                      @override                     public void onnext(datasnapshot datasnapshot) {                          genericclass genericclass = retrieveinfoaboutnode(datasnapshot);                          handle(datasnapshot, genericclass);                      }                 });     }

actually, permissions not cause of issue.

i've had 'invocationtargetexception' because of realm incorrect thread. why error 'permissions denied' still puzzle me.


Comments

Post a Comment

Popular posts from this blog

php - Vagrant up error - Uncaught Reflection Exception: Class DOMDocument does not exist -

i've set bento/ubuntu-16.04 vagrant box using php 5.6, , getting following error quite few times when try , run shell script: "uncaught reflection exception: class domdocument not exist". i've tried adding following top of script (not together), each no success: "sudo apt-get install php5.6-xml", "sudo apt-get install php5-xml", "sudo apt-get install php-dom" i've tried resetting server "sudo service apache2 restart". does have suggestions?
Read more

vue.js - Create hooks for automated testing -

Image
qa guys complained can't automate frontend testing. because our html looks same outside. lazy hack did this <template> <div :role="$options.name"> ... </div> </template> <script> export default { name: 'vmcomponentname' } </script> which takes name script , applies html. in browser get: <div role="vmcomponentname"> ... </div> line :role="$options.name" goes in every component. is there dry er solutions? please share. additional details i'll explain in details looking for. imagine have vmusercreate form creates user. test case can create user . to automatically test without role, have use following selector: .wrapper > .wrapper > .wrapper > .submit-button the test extremely brittle (will break lot). if use roles can use [role="vmusercreateform"] .submit-button selector. many folds less brittle. so basically, i'm ...
Read more

Add new key value to json node in java -

i have json file : { "id":1, "name":"abc", "addressdetails": { "city":"newyork" } } i wanted add 1 more key-value ("pincode" : "414141") node 'addressdetails'. i tried using : objectmapper mapper = new objectmapper(); jsonnode root = mapper.readtree(new file("d://test.json")); objectnode node = mapper.createobjectnode(); node.with("addressdetails").put("pincode", "414141"); but it's not getting added, there way can ? you can try you should modify file path objectmapper mapper = new objectmapper(); objectnode nodes = mapper.readvalue(new file("d:\\test.txt"), objectnode.class); nodes.with("addressdetails").put("pincode", "414141"); mapper.writer().writevalue(new file("d:\\test.txt"), nodes);
Read more