VolleyX

Volley + RxJava, use Volley the Rx way

Motivation

Some android developer is still using volley as their network library, and it should be combined with RxJava to make the bes of it. There is another Volley + RxJava library, here, but it integrated the volley src code and modify it, which makes volley can not be upgraded independently. This library integrate with volley independently and you can using volley the original way.

Usage

compile 'com.github.yangweigbh:volleyx:1.0.0'

this project depend on

'com.android.volley:volley:1.0.0'

'io.reactivex:rxjava:1.2.1'

if you want to use different version of rxjava and volley, add

compile('com.github.yangweigbh:volleyx:1.0.0') {
    transitive = false
}

Step1: Init in the application onCreate, then everything is OK

public class MyApplication extends Application {
    @Override
    public void onCreate() {
        super.onCreate();
        VolleyX.init(this);
    }
}

Step2: Create request as usual, instead don't set the response listener and the error listner cause we will do it RxWay, use VolleyX.from(requsest) to create a Observable

final StringRequest request = new StringRequest(URL, null, null);
VolleyX.from(request).subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<String>() {
            @Override
            public void onCompleted() {
                Log.d(TAG, "onCompleted");
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "onError " + Log.getStackTraceString(e));
            }

            @Override
            public void onNext(String result) {
                Log.d(TAG, "onNext");
            }
        });

If you have custom request, the pass the response listener field name as 2nd param to the from

GsonRequest<Result> request = new GsonRequest<>(URL, Result.class, null, null);
VolleyX.from(request, "mListener1").subscribeOn(Schedulers.io())
         .subscribe(new Observer<Result>() {
            @Override
            public void onCompleted() {
                Log.d(TAG, "onCompleted");
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "onError " + Log.getStackTraceString(e));
            }

            @Override
            public void onNext(Result result) {
                Log.d(TAG, "onNext");
            }
        });

By default, the VolleyX use the default volley request queue, you can set custom requestqueue with

 VolleyX.setRequestQueue(your custom queue);

any other usage, please refer to the demo