feat: port volley example

 port example Networking with Volley

Author: Kaushik Gopal

app/src/main/java/com/morihacky/android/rxjava/volley/MyVolley.java

@@ -6,8 +6,6 @@
 
 /**
  * Helper class that is used to provide references to initialized RequestQueue(s) and ImageLoader(s)
- *
- * @author Ognyan Bankov
  */
 public class MyVolley {
     private static RequestQueue mRequestQueue;
@@ -20,7 +18,7 @@ public static void init(Context context) {
         mRequestQueue = Volley.newRequestQueue(context);
     }
 
-    public static RequestQueue getRequestQueue() {
+    static RequestQueue getRequestQueue() {
         if (mRequestQueue != null) {
             return mRequestQueue;
         } else {

app/src/main/java/com/morihacky/android/rxjava/volley/VolleyDemoFragment.java

@@ -9,30 +9,26 @@
 import android.view.View;
 import android.view.ViewGroup;
 import android.widget.ListView;
-
+import butterknife.Bind;
+import butterknife.ButterKnife;
+import butterknife.OnClick;
 import com.android.volley.Request;
 import com.android.volley.VolleyError;
 import com.android.volley.toolbox.JsonObjectRequest;
 import com.android.volley.toolbox.RequestFuture;
 import com.morihacky.android.rxjava.R;
 import com.morihacky.android.rxjava.fragments.BaseFragment;
 import com.morihacky.android.rxjava.wiring.LogAdapter;
-
-import org.json.JSONObject;
-
+import io.reactivex.Flowable;
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.disposables.CompositeDisposable;
+import io.reactivex.schedulers.Schedulers;
+import io.reactivex.subscribers.DisposableSubscriber;
 import java.nio.charset.Charset;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.ExecutionException;
-
-import butterknife.Bind;
-import butterknife.ButterKnife;
-import butterknife.OnClick;
-import rx.Observable;
-import rx.Observer;
-import rx.android.schedulers.AndroidSchedulers;
-import rx.schedulers.Schedulers;
-import rx.subscriptions.CompositeSubscription;
+import org.json.JSONObject;
 import timber.log.Timber;
 
 public class VolleyDemoFragment
@@ -45,7 +41,7 @@ public class VolleyDemoFragment
     private List<String> _logs;
     private LogAdapter _adapter;
 
-    private CompositeSubscription _compositeSubscription = new CompositeSubscription();
+    private CompositeDisposable _disposables = new CompositeDisposable();
 
     @Override
     public View onCreateView(LayoutInflater inflater,
@@ -65,7 +61,7 @@ public void onActivityCreated(@Nullable Bundle savedInstanceState) {
     @Override
     public void onPause() {
         super.onPause();
-        _compositeSubscription.clear();
+        _disposables.clear();
     }
 
     @Override
@@ -75,18 +71,18 @@ public void onDestroyView() {
     }
 
     /**
-     * Creates and returns an observable generated from the Future returned from 
+     * Creates and returns an observable generated from the Future returned from
      * {@code getRouteData()}. The observable can then be subscribed to as shown in
      * {@code startVolleyRequest()}
      * @return Observable<JSONObject>
      */
-    public Observable<JSONObject> newGetRouteData() {
-        return Observable.defer(() -> {
+    public Flowable<JSONObject> newGetRouteData() {
+        return Flowable.defer(() -> {
             try {
-                return Observable.just(getRouteData());
+                return Flowable.just(getRouteData());
             } catch (InterruptedException | ExecutionException e) {
                 Log.e("routes", e.getMessage());
-                return Observable.error(e);
+                return Flowable.error(e);
             }
         });
     }
@@ -97,38 +93,44 @@ void startRequest() {
     }
 
     private void startVolleyRequest() {
-        _compositeSubscription.add(newGetRouteData().subscribeOn(Schedulers.io())
+        DisposableSubscriber<JSONObject> d = new DisposableSubscriber<JSONObject>() {
+            @Override
+            public void onNext(JSONObject jsonObject) {
+                Log.e(TAG, "onNext " + jsonObject.toString());
+                _log("onNext " + jsonObject.toString());
+
+            }
+
+            @Override
+            public void onError(Throwable e) {
+                VolleyError cause = (VolleyError) e.getCause();
+                String s = new String(cause.networkResponse.data, Charset.forName("UTF-8"));
+                Log.e(TAG, s);
+                Log.e(TAG, cause.toString());
+                _log("onError " + s);
+
+            }
+
+            @Override
+            public void onComplete() {
+                Log.e(TAG, "onCompleted");
+                Timber.d("----- onCompleted");
+                _log("onCompleted ");
+            }
+        };
+
+        newGetRouteData()
+              .subscribeOn(Schedulers.io())
               .observeOn(AndroidSchedulers.mainThread())
-              .subscribe(new Observer<JSONObject>() {
-                  @Override
-                  public void onCompleted() {
-                      Log.e(TAG, "onCompleted");
-                      Timber.d("----- onCompleted");
-                      _log("onCompleted ");
-                  }
-
-                  @Override
-                  public void onError(Throwable e) {
-                      VolleyError cause = (VolleyError) e.getCause();
-                      String s = new String(cause.networkResponse.data, Charset.forName("UTF-8"));
-                      Log.e(TAG, s);
-                      Log.e(TAG, cause.toString());
-                      _log("onError " + s);
-
-                  }
-
-                  @Override
-                  public void onNext(JSONObject jsonObject) {
-                      Log.e(TAG, "onNext " + jsonObject.toString());
-                      _log("onNext " + jsonObject.toString());
-
-                  }
-              }));
+              .subscribe(d);
+
+        _disposables.add(d);
     }
+
     /**
      * Converts the Asynchronous Request into a Synchronous Future that can be used to
      * block via {@code Future.get()}. Observables require blocking/synchronous functions
-     * @return JSONObject 
+     * @return JSONObject
      * @throws ExecutionException
      * @throws InterruptedException
      */