Replace listeners with RxJava

Question

Replace listeners with RxJava

Navigation

#1 by (0 votes)

2

I am beginning to know the advantages of RxJava, and I would like someone to lend me a hand to get to the point.

The issue would be to modify this code made with listeners:

public void getData( final OnResponseListener listener ){
    if(data!=null && !data.isEmpty()){
        listener.onSuccess();
    }
    else{
        listener.onError();
    }
}

Listener:

public interface OnResponseListener {

    public void onSuccess();

    public void onError(); 
}

And the one who listens:

 object.getData( new OnResponseListener() {
            @Override
            public void onSuccess() {
                Log.w(TAG," on success");
            }

            @Override
            public void onError() {
                Log.e(TAG," on error");
            }
        });

How to do this with observables? Thanks

java android rxjava

asked by Pablo Cegarra 07.02.2017 в 17:35

source

1 answer

Send email depending on the date My Java program does not allow me to enter a menu

score 0 · Accepted Answer

The solution I am using is the following:

public static Single<List<Data>> getData() {

        return Single.create(singleSubscriber -> {

                if(data!=null){
                    singleSubscriber.onSuccess(data);
                }
                else{
                    singleSubscriber.onError(new Exception("no data"));
                }
            });
        });
    }

And to receive the data:

 Single<List<Data>> data = Api.getData();
        data.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new SingleObserver<List<Data>>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onSuccess(List<Data> data) {
                        mAdapter.addItems(data);
                    }

                    @Override
                    public void onError(Throwable e) {
                        showError();
                    }
                });
    }