Home

ObservableScheduler wiki ###基础demo:

 Subscription mSubscription = JObservable.create(new JObservable.OnSubscribe<List<Bitmap>>() {
            @Override
            public void call(SubscribeManager<List<Bitmap>> mSubscriber) {
                try {
                    //TODO... 
                    mSubscriber.notifyData(bitmaps);
                } catch (Exception e) {
                    mSubscriber.error(e);
                }

            }
        }).workedOn(Schedules.background())
                .subscribeOn(Schedules.mainThread())
                .subscribe(new Subscriber<List<Bitmap>>() {

                    @Override
                    public void onStart() {
                        super.onStart();
                        //TODO... 
                    }

                    @Override
                    public void onAfter() {
                        super.onAfter();
                         //TODO... 
                    }

                    @Override
                    public void notifyData(List<Bitmap> strings) {
                      //TODO... 
                    }
                    @Override
                    public void error(Throwable t) {
                      //TODO... 
                    }
                });

如果想取消当前任务则调用:

mSubscription.unsubscribe();