log/comment removal

Author: Mohit Pandey

ReactiveAndroid/src/main/java/com/mohit/reactiveandroid/GridAdapter.java

@@ -2,19 +2,15 @@
 
 
 import android.content.Context;
-import android.util.Log;
 import android.view.LayoutInflater;
 import android.view.View;
 import android.view.ViewGroup;
 import android.widget.BaseAdapter;
 import android.widget.ImageView;
 import android.widget.TextView;
-import android.widget.Toast;
 import com.squareup.picasso.Picasso;
 import rx.Observable;
 import rx.android.schedulers.AndroidSchedulers;
-import rx.functions.Action1;
-import rx.functions.Func1;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -23,43 +19,21 @@ public class GridAdapter extends BaseAdapter {
 
     private Context context;
     private static final NetworkManager networkManager = new NetworkManager();
-    private static final String TAG = "r3ader";
-
     private List<Movie> movies = new ArrayList<Movie>();
 
-    public GridAdapter(Context context,String source) {
+    public GridAdapter(Context context, String source) {
         this.context = context;
         networkManager.getData(source)
-        .flatMap(data -> new FeedParser().getMovies(data))
-        .observeOn(AndroidSchedulers.mainThread())
-        .onErrorFlatMap(e->Observable.empty())
-        .subscribe((Movies m) -> {
-            movies.clear();
-            movies.addAll(m.movies);
-            notifyDataSetChanged();
-        });
+                .flatMap(data -> new FeedParser().getMovies(data))
+                .observeOn(AndroidSchedulers.mainThread())
+                .onErrorFlatMap(e -> Observable.empty())
+                .subscribe((Movies m) -> {
+                    movies.clear();
+                    movies.addAll(m.movies);
+                    notifyDataSetChanged();
+                });
     }
 
-    /*
-    .flatMap(new Func1<String, Observable<Movies>>() {
-        @Override
-        public Observable<Movies> call(String data) {
-            return new FeedParser().getMovies(data);
-        }
-    })
-    */
-//    public void setAdapterSource(String url) {
-//        Log.e(TAG,"Why is this getting called");
-//        networkManager.getData(url)
-//                .flatMap(data -> new FeedParser().getMovies(data))
-//                .observeOn(AndroidSchedulers.mainThread())
-//                .subscribe((Movies m) -> {
-//                    movies.clear();
-//                    movies.addAll(m.movies);
-//                    notifyDataSetChanged();
-//                });
-//    }
-
     public int getCount() {
         return movies.size();
     }

ReactiveAndroid/src/main/java/com/mohit/reactiveandroid/MainActivity.java

@@ -5,12 +5,9 @@
 import android.os.Bundle;
 import android.support.v13.app.FragmentPagerAdapter;
 import android.support.v4.view.ViewPager;
-import android.util.Log;
 import android.view.*;
 import android.widget.GridView;
 
-import java.util.Locale;
-
 public class MainActivity extends Activity implements ActionBar.TabListener {
 
     /**
@@ -42,7 +39,7 @@ protected void onCreate(Bundle savedInstanceState) {
         int sections = 4;
         // Create the adapter that will return a fragment for each of the three
         // primary sections of the activity.
-        mSectionsPagerAdapter = new SectionsPagerAdapter(getFragmentManager(), this,sections);
+        mSectionsPagerAdapter = new SectionsPagerAdapter(getFragmentManager(), this, sections);
 
         // Set up the ViewPager with the sections adapter.
         mViewPager = (ViewPager) findViewById(R.id.pager);
@@ -57,8 +54,8 @@ public void onPageSelected(int position) {
                 actionBar.setSelectedNavigationItem(position);
             }
         });
-        String [] sectionNames = {"In Theaters","DVD Releases","Opening","Box Office"};
-        for(int i=0;i<sections;i++) {
+        String[] sectionNames = {"In Theaters", "DVD Releases", "Opening", "Box Office"};
+        for (int i = 0; i < sections; i++) {
             actionBar.addTab(actionBar.newTab().setText(sectionNames[i]).setTabListener(this));
         }
     }
@@ -114,7 +111,7 @@ public class SectionsPagerAdapter extends FragmentPagerAdapter {
                 "http://api.rottentomatoes.com/api/public/v1.0/lists/movies/box_office.json?page_limit=24&page=1&country=us&apikey="
         };
 
-        public SectionsPagerAdapter(FragmentManager fm, Context context,int sections) {
+        public SectionsPagerAdapter(FragmentManager fm, Context context, int sections) {
             super(fm);
             this.context = context;
             this.sections = sections;
@@ -124,8 +121,8 @@ public SectionsPagerAdapter(FragmentManager fm, Context context,int sections) {
         public Fragment getItem(int position) {
             // getItem is called to instantiate the fragment for the given page.
             // Return a PlaceholderFragment (defined as a static inner class below).
-            GridAdapter gridAdapter = new GridAdapter(this.context,LIST[position]);
-            return PlaceholderFragment.newInstance(position, context,gridAdapter);
+            GridAdapter gridAdapter = new GridAdapter(this.context, LIST[position]);
+            return PlaceholderFragment.newInstance(position, context, gridAdapter);
         }
 
         @Override
@@ -147,11 +144,12 @@ public static class PlaceholderFragment extends Fragment {
 
         private int position;
         private GridAdapter gridAdapter;
+
         /**
          * Returns a new instance of this fragment for the given section
          * number.
          */
-        public static PlaceholderFragment newInstance(int sectionNumber, Context context,GridAdapter gridAdapter) {
+        public static PlaceholderFragment newInstance(int sectionNumber, Context context, GridAdapter gridAdapter) {
             PlaceholderFragment fragment = new PlaceholderFragment();
             Bundle args = new Bundle();
             args.putInt(ARG_SECTION_NUMBER, sectionNumber);
@@ -168,7 +166,6 @@ public PlaceholderFragment() {
         public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {
             View rootView = inflater.inflate(R.layout.fragment_main, container, false);
             GridView gridview = (GridView) rootView.findViewById(R.id.gridView);
-            Log.e(TAG,"Create view" + position);
             gridview.setAdapter(gridAdapter);
             return rootView;
         }

ReactiveAndroid/src/main/java/com/mohit/reactiveandroid/NetworkManager.java

@@ -28,37 +28,16 @@ public class NetworkManager {
 
     private OkHttpClient client = new OkHttpClient();
 
-    private static final String TAG = "r3ader";
+    private static final String TAG = "reactive";
 
     public NetworkManager() {
     }
 
     public Observable<String> getData(final String url) {
-
-        /*
-        .onErrorReturn(e->{
-            return "{movies:[]}";
-        });
-         */
         return  Async.start(()->getContent(url),Schedulers.io());
-//        return Observable.create((Observer<? super String> observer) ->{
-//                try {
-//                    Log.d("r3ader", "downloading on "+Thread.currentThread().toString());
-//                    String data = getContent(url);
-//                    Log.d("r3ader", "done downloading on "+Thread.currentThread().toString());
-//                    observer.onNext(data);
-//                    observer.onCompleted();
-//                } catch (Exception e) {
-//                    observer.onError(e);
-//                }
-//
-//                return Subscriptions.empty();
-//        })
-//        .subscribeOn(Schedulers.io());
     }
 
     public String getContent(String urlString) {
-        Log.e(TAG,"calling "+urlString);
         try {
             HttpURLConnection connection = client.open(new URL(urlString));
             byte [] bytes = readData(connection.getInputStream(), connection);
@@ -76,7 +55,6 @@ private byte[] readData(InputStream inputStream, HttpURLConnection connection) t
             byte[] data = new byte[0];
             final int contentLength = connection.getContentLength();
             if (contentLength > 0) {
-                Log.d(TAG,"length "+contentLength);
                 outputStream = new ByteArrayOutputStream(contentLength);
             } else {
                 outputStream = new ByteArrayOutputStream();