Scheduler.scheduleRecursive
Scheduler.scheduleRecursive

Make recursive scheduling a first-class citizen without needing to refer to "this" which doesn't work inside lambdas (Java8/Scala/etc).

        Schedulers.newThread().scheduleRecursive(new Action1<Recurse>() {
            @Override
            public void call(Recurse r) {
                System.out.println("do stuff on thread: " + Thread.currentThread() + " Time: " + System.nanoTime());
                r.schedule(100, TimeUnit.MILLISECONDS);
            }
        });

mobilist/RxJava,weikipeng/RxJava,jbripley/RxJava,msdgwzhy6/RxJava,takecy/RxJava,sunfei/RxJava,KevinTCoughlin/RxJava,tombujok/RxJava,androidgilbert/RxJava,sposam/RxJava,wehjin/RxJava,Turbo87/RxJava,wrightm/RxJava,AttwellBrian/RxJava,ibaca/RxJava,akarnokd/RxJava,gjesse/RxJava,vqvu/RxJava,ReactiveX/RxJava,nkhuyu/RxJava,picnic106/RxJava,java02014/RxJava,sanxieryu/RxJava,AttwellBrian/RxJava,maugomez77/RxJava,shekarrex/RxJava,java02014/RxJava,suclike/RxJava,AmberWhiteSky/RxJava,Shedings/RxJava,Ryan800/RxJava,suclike/RxJava,lncosie/RxJava,devagul93/RxJava,hyarlagadda/RxJava,nurkiewicz/RxJava,NiteshKant/RxJava,spoon-bot/RxJava,devisnik/RxJava,maugomez77/RxJava,abersnaze/RxJava,randall-mo/RxJava,sitexa/RxJava,androidgilbert/RxJava,zsxwing/RxJava,hyarlagadda/RxJava,tilal6991/RxJava,zhongdj/RxJava,davidmoten/RxJava,Shedings/RxJava,artem-zinnatullin/RxJava,xfumihiro/RxJava,ayushnvijay/RxJava,rabbitcount/RxJava,onepavel/RxJava,gjesse/RxJava,ibaca/RxJava,tombujok/RxJava,wehjin/RxJava,lncosie/RxJava,ChenWenHuan/RxJava,TracyLu/RxJava,dromato/RxJava,java02014/RxJava,davidmoten/RxJava,ronenhamias/RxJava,yuhuayi/RxJava,ppiech/RxJava,ashwary/RxJava,Siddartha07/RxJava,nvoron23/RxJava,onepavel/RxJava,southwolf/RxJava,ruhkopf/RxJava,cgpllx/RxJava,devisnik/RxJava,nkhuyu/RxJava,Ribeiro/RxJava,frodoking/RxJava,mttkay/RxJava,sitexa/RxJava,A-w-K/RxJava,msdgwzhy6/RxJava,eduardotrandafilov/RxJava,Eagles2F/RxJava,devisnik/RxJava,Eagles2F/RxJava,mattrjacobs/RxJava,rabbitcount/RxJava,hzysoft/RxJava,jbripley/RxJava,nvoron23/RxJava,eduardotrandafilov/RxJava,Bobjoy/RxJava,lijunhuayc/RxJava,devagul93/RxJava,marcogarcia23/RxJava,nvoron23/RxJava,ayushnvijay/RxJava,cloudbearings/RxJava,picnic106/RxJava,androidyue/RxJava,dromato/RxJava,ayushnvijay/RxJava,zjrstar/RxJava,kuanghao/RxJava,reactivex/rxjava,nurkiewicz/RxJava,fjg1989/RxJava,zsxwing/RxJava,ronenhamias/RxJava,ypresto/RxJava,fjg1989/RxJava,bboyfeiyu/RxJava,NiteshKant/RxJava,xfumihiro/RxJava,xfumihiro/RxJava,YlJava110/RxJava,randall-mo/RxJava,wlrhnh-David/RxJava,markrietveld/RxJava,bboyfeiyu/RxJava,simonbasle/RxJava,duqiao/RxJava,pitatensai/RxJava,cgpllx/RxJava,TracyLu/RxJava,puniverse/RxJava,weikipeng/RxJava,kuanghao/RxJava,mttkay/RxJava,vqvu/RxJava,zhongdj/RxJava,KevinTCoughlin/RxJava,KevinTCoughlin/RxJava,Godchin1990/RxJava,abersnaze/RxJava,elijah513/RxJava,devagul93/RxJava,jacek-rzrz/RxJava,zjrstar/RxJava,aditya-chaturvedi/RxJava,jbripley/RxJava,Godchin1990/RxJava,akarnokd/RxJava,ashwary/RxJava,sanxieryu/RxJava,A-w-K/RxJava,klemzy/RxJava,zsxwing/RxJava,elijah513/RxJava,ypresto/RxJava,wlrhnh-David/RxJava,forsail/RxJava,kuanghao/RxJava,tilal6991/RxJava,artem-zinnatullin/RxJava,mttkay/RxJava,YlJava110/RxJava,forsail/RxJava,sunfei/RxJava,HuangWenhuan0/RxJava,aditya-chaturvedi/RxJava,takecy/RxJava,ppiech/RxJava,shekarrex/RxJava,klemzy/RxJava,mobilist/RxJava,Siddartha07/RxJava,pitatensai/RxJava,AmberWhiteSky/RxJava,simonbasle/RxJava,srayhunter/RxJava,gjesse/RxJava,yuhuayi/RxJava,msdgwzhy6/RxJava,wrightm/RxJava,fjg1989/RxJava,zjrstar/RxJava,androidyue/RxJava,Eagles2F/RxJava,nurkiewicz/RxJava,eduardotrandafilov/RxJava,TracyLu/RxJava,ChenWenHuan/RxJava,frodoking/RxJava,A-w-K/RxJava,jacek-rzrz/RxJava,Siddartha07/RxJava,tombujok/RxJava,klemzy/RxJava,cloudbearings/RxJava,southwolf/RxJava,onepavel/RxJava,aditya-chaturvedi/RxJava,simonbasle/RxJava,ChenWenHuan/RxJava,marcogarcia23/RxJava,srayhunter/RxJava,Ryan800/RxJava,Bobjoy/RxJava,hyleung/RxJava,runt18/RxJava,ruhkopf/RxJava,hzysoft/RxJava,markrietveld/RxJava,hyarlagadda/RxJava,elijah513/RxJava,HuangWenhuan0/RxJava,sposam/RxJava,rabbitcount/RxJava,b-cuts/RxJava,vqvu/RxJava,duqiao/RxJava,runt18/RxJava,picnic106/RxJava,cgpllx/RxJava,Shedings/RxJava,benjchristensen/RxJava,tilal6991/RxJava,Turbo87/RxJava,stevegury/RxJava,YlJava110/RxJava,davidmoten/RxJava,b-cuts/RxJava,shekarrex/RxJava,puniverse/RxJava,sunfei/RxJava,wehjin/RxJava,mattrjacobs/RxJava,stevegury/RxJava,southwolf/RxJava,hyleung/RxJava,ruhkopf/RxJava,weikipeng/RxJava,runt18/RxJava,hzysoft/RxJava,jacek-rzrz/RxJava,androidyue/RxJava,b-cuts/RxJava,takecy/RxJava,Ryan800/RxJava,AmberWhiteSky/RxJava,androidgilbert/RxJava,marcogarcia23/RxJava,forsail/RxJava,lijunhuayc/RxJava,Bobjoy/RxJava,Godchin1990/RxJava,sanxieryu/RxJava,devisnik/RxJava,abersnaze/RxJava,zhongdj/RxJava,spoon-bot/RxJava,markrietveld/RxJava,sitexa/RxJava,lncosie/RxJava,ibaca/RxJava,stevegury/RxJava,jtulach/RxJava,wrightm/RxJava,Ribeiro/RxJava,wlrhnh-David/RxJava,puniverse/RxJava,reactivex/rxjava,HuangWenhuan0/RxJava,lijunhuayc/RxJava,Turbo87/RxJava,ashwary/RxJava,srayhunter/RxJava,frodoking/RxJava,mattrjacobs/RxJava,nkhuyu/RxJava,duqiao/RxJava,maugomez77/RxJava,ReactiveX/RxJava,pitatensai/RxJava,cloudbearings/RxJava,suclike/RxJava,dromato/RxJava,Ribeiro/RxJava,hyleung/RxJava,sposam/RxJava,yuhuayi/RxJava,jtulach/RxJava,ppiech/RxJava,ronenhamias/RxJava,ypresto/RxJava,abersnaze/RxJava,randall-mo/RxJava