android - Converting this AsyncTask to RxAndroid? -

-

bit new rx, looking on converting following asynctask rx, can visualize rx bit more code know something. i've found few other answers relevant, alot of them werent network requests , many used different operators different answers, bit confused.

heres asynctask:

public class backgroundstuff extends asynctask<void, void, void> {      @override     protected void doinbackground(void... params) {          useragent myuseragent = useragent.of("xxx:xxxx:xxx");          redditclient redditclient = new redditclient(myuseragent);         credentials credentials = credentials.userlessapp("xxxxxxxx", uuid.randomuuid());         oauthdata authdata = null;         try {             authdata = redditclient.getoauthhelper().easyauth(credentials);             redditclient.authenticate(authdata);         } catch (oauthexception e) {             e.printstacktrace();         }          subredditpaginator sp = new subredditpaginator(redditclient);          sp.setlimit(7);         sp.setsorting(sorting.hot);         sp.settimeperiod(timeperiod.day);          sp.setsubreddit("pics");          sp.next(true);         listing<submission> list = sp.getcurrentlisting();          submission sub = list.get(1);         (submission submission : list) {             log.d("test", "title: " + submission.gettitle());         }         submission sub2 = redditclient.getsubmission(sub.getid());         system.out.println(sub2.getcomments().get(0).getcomment().getbody());           return null;     } }

for reference, authenticates reddit , grabs results particular subreddit.

i know need observable, , .suscribeon(schedulers.newthread()) , .observeon(androidschedulers.mainthread()), not sure how make observable.

wrap in function:

    void dosomething(){     useragent myuseragent = useragent.of("xxx:xxxx:xxx");      redditclient redditclient = new redditclient(myuseragent);     credentials credentials = credentials.userlessapp("xxxxxxxx", uuid.randomuuid());     oauthdata authdata = null;     try {         authdata = redditclient.getoauthhelper().easyauth(credentials);         redditclient.authenticate(authdata);     } catch (oauthexception e) {         e.printstacktrace();     }      subredditpaginator sp = new subredditpaginator(redditclient);      sp.setlimit(7);     sp.setsorting(sorting.hot);     sp.settimeperiod(timeperiod.day);      sp.setsubreddit("pics");      sp.next(true);     listing<submission> list = sp.getcurrentlisting();      submission sub = list.get(1);     (submission submission : list) {         log.d("test", "title: " + submission.gettitle());     }     submission sub2 = redditclient.getsubmission(sub.getid());     system.out.println(sub2.getcomments().get(0).getcomment().getbody());       return null;     }

wrap in observable:

observable.just(dosomething);

wrap in defer run when subscribes it:

observable<void> dosomethingobservable = observable.defer(()-> observable.just(dosomething))

decide run subscribeon , observeon, , subscribe make run:

dosomethingobservable .suscribeon(schedulers.newthread()) .observeon(androidschedulers.mainthread()).subscribe();

Comments

Post a Comment

Popular posts from this blog

Delphi XE2 Indy10 udp client-server interchange using SendBuffer-ReceiveBuffer -

-
i use delphi xe2 , indy10 udp protocol. can't receive server echo on client side if use receivebuffer method. got "socket error # 10040" although send small echo message server client. console application illustrate problem below. in advance. program project1; {$apptype console} {$r *.res} uses system.sysutils, idglobal, idbasecomponent, idcomponent, idsockethandle, idudpclient, idudpserver, idudpbase, idstack; type tudp_serv = class(tidudpserver) procedure udpsvudpread(athread: tidudplistenerthread; adata: tidbytes; abinding: tidsockethandle); end; var udpserver: tudp_serv; udpcl: tidudpclient; bsnd, brcv: tbytes; s: string; k: integer; //============================================================================== procedure tudp_serv.udpsvudpread(athread: tidudplistenerthread; adata: tidbytes; abinding: tidsockethandle); begin writeln(' server read: ' + tohex(adata, length(adata))); abinding sendto(peerip, peerport, adat...
Read more

Qt ActiveX WMI QAxBase::dynamicCallHelper: ItemIndex(int): No such property in -

-
i new windows programming. here goes code objiwbemlocator = new qaxobject("wbemscripting.swbemlocator"); objwmiservice = objiwbemlocator->querysubobject("connectserver(qstring&,qstring&)",qstring("."),qstring("root\\cimv2")); qaxobject* returnlist = objwmiservice->querysubobject("execquery(qstring&)", qstring("select * %1").arg(domain)); qaxobject* result = returnlist->querysubobject("itemindex(int)", 0); i getting error on runtime qt activex wmi qaxbase::dynamiccallhelper: itemindex(int): no such property in but itemindex method exists msdn says the itemindex method not work collections not contain swbemobjects, such swbemmethodset, swbemnamedvalueset, swbemprivilegeset, swbempropertyset, , swbemqualifierset. what selecting ? have tried iterating on collection ? plus need minimum windows vista itemindex method. hope helps
Read more

Enable autocomplete or intellisense in Atom editor for PHP -

-
i'm first time user of atom editor php code. atom can autocomplete built-in functions of php. possible make editor autocomplete custom function written in separate file? function.php <?php function printsomething() { echo "hello world"; } index.php <?php require_once "function.php"; printsomething(); // autocompleted atom editor while typing thanks in advance. there text file in %userprofile%.atom called snippets.cson. in there can add snippet. more this: http://flight-manual.atom.io/using-atom/sections/snippets/ but need think can use later on other files well. otherwise need copy , paste.
Read more