java - Realm access from incorrect thread Exception while a copy was sent using copyFromRealm -

-

when streaming copy of realm objects instead of realm reference , observing on schedulers.io thread, there crash famous exception message "realm access incorrect thread. realm objects can accessed in thread created."

shouldn't copy thread free? can produce 1 thread , process on different thread?

this how creating observable.

 public observable<brand> getallbrands() {     return realm.where(brand.class)             .findall()             .asobservable()             .flatmap(observable::from)             .map(brand -> realm.copyfromrealm(brand)); }

following how observe getallbrands().

 observable<brand> brandobservable = datamanager.getallbrands();      brandobservable.observeon(androidschedulers.mainthread())             .subscribeon(schedulers.io())             .subscribe(new observer<brand>() {                 @override                 public void oncompleted() {                     log.d("reactive", "completed");                 }                  @override                 public void onerror(throwable e) {                     log.d("reactive", e.getmessage());                 }                  @override                 public void onnext(brand brand) {                     datasource.add(brand.getname());                     myadapter.notifydatasetchanged();                 }             });

you subscribing on schedulers.io while using realm instance ui thread:

realm.where(brand.class)         .findall()         .asobservable()         .flatmap(observable::from)         .map(brand -> realm.copyfromrealm(brand)) // realm instance on wrong thread         .subscribeon(schedulers.io());

what after easy way move query across threads, still work-in-progress here: https://github.com/realm/realm-java/pull/1978. until can work around doing this:

public observable<brand> getallbrands(final realm realm) {     return observable.create(new observable.onsubscribe<list<brand>>() {         @override         public void call(final subscriber<? super list<brand>> subscriber) {             realm obsrealm = realm.getinstance(realm.getconfiguration());             final realmresults<brand> results = obsrealm.where(brand.class).findall();             final realmchangelistener listener = new realmchangelistener() {                 @override                 public void onchange() {                     subscriber.onnext(realm.copyfromrealm(results));                 }             };             results.addchangelistener(listener);             subscriber.add(subscriptions.create(new action0() {                 @override                 public void call() {                     realm.removechangelistener(listener);                     realm.close();                 }             }));          }     })     .flatmap(observable::from); }

note realm changelisteners work on looper threads means need change worker thread h 

handlerthread bgthread = new handlerthread("workerthread"); handler handler = new handler(bgthread.getlooper());  getallbrands(realm).subscribeon(handlerscheduler.from(handler));

Comments

Post a Comment

Popular posts from this blog

java - Run spring boot application error: Cannot instantiate interface org.springframework.context.ApplicationListener -

-
i have spring project , try make use spring boot , run @ embadded tomcat following : https://spring.io/guides/gs/rest-service/ this application //@configuration //@enableaspectjautoproxy @springbootapplication @componentscan(basepackages = "gux.prome") public class application { public static void main(string[] args) { springapplication.run(application.class, args); } } if use maven command: mvn spring-boot:run , project starts fine, need debug , run main method @ intelij, exception occurs: exception in thread "main" java.lang.illegalargumentexception: cannot instantiate interface org.springframework.context.applicationlistener : org.springframework.boot.logging.classpathloggingapplicationlistener @ org.springframework.boot.springapplication.createspringfactoriesinstances(springapplication.java:414) @ org.springframework.boot.springapplication.getspringfactoriesinstances(springapplication.java:394) @ org.springframework.bo...
Read more

reactjs - React router and this.props.children - how to pass state to this.props.children -

-
i'm using react-router first time , don't know how think in yet. here's how i'm loading components in nested routes. entry point .js reactdom.render( <router history={hashhistory} > <route path="/" component={app}> <route path="models" component={content}> </route> </router>, document.getelementbyid('app') ); app.js render: function() { return ( <div> <header /> {this.props.children} </div> ); } so child of app content component sent in. i'm using flux , app.js has state , listens changes, don't know how pass state down this.props.children. before using react-router app.js defines children explicitly, passing state natural don't see how now. using couple of react helper methods can add state, props , whatever else this.props.children render: function() { var children = react.ch...
Read more

Excel VBA "Microsoft Windows Common Controls 6.0 (SP6)" Location Changes -

-
i have excel workbook used generate quotations customers. there main page user inputs data, , there buttons generate various pdfs , send them customer. however, 1 user consistently getting error preventing generating , sending pdfs. i beleive "microsoft windows common controls 6.0 (sp6)". it's installed on users' computers. on mine, location "c:\windows\syswow64\mscomctl.ocx" on others "c:\windows\system32\mscomctl.ocx" the user experiencing issues on 32-bit machine, "mscomctl.ocx" file should in system32. have manually put in there, , pointed common controls reference in vba it. issue seems keep reverting looking in syswow64. since folder doesn't exist, can't find it, , can't produce pdfs. i thought perhaps issue user running older version of office (2007) there users on 2013 , 2016. thought perhaps mixture of 64-bit , 32-bit users. user gets sent workbook other users (as quotation process goes further, gets passed ...
Read more