Updating the new sample to demonstrate UI binding

This commit binds the observable to a method where a user can update their UI accordingly.

Author: Zachary Siegel

rxjava-contrib/rxjava-android-samples/samples/src/main/AndroidManifest.xml

@@ -9,7 +9,7 @@
         android:theme="@style/AppTheme"
         android:label="@string/app_name">
         <activity
-                android:name=".RetainedFragmentActivityV2">
+                android:name=".UIBindingActivity">
 
             <intent-filter>
                 <category android:name="android.intent.category.LAUNCHER"/>

rxjava-contrib/rxjava-android-samples/samples/src/main/java/com/netflix/rxjava/android/samples/RetainedFragmentActivityV2.java renamed to rxjava-contrib/rxjava-android-samples/samples/src/main/java/com/netflix/rxjava/android/samples/UIBindingActivity.java

@@ -19,32 +19,32 @@
 import rx.subscriptions.Subscriptions;
 
 /**
- * A retained fragment whose goals are below
- *
- * 1) gracefully handle rotation - not losing any data
- * 2) gracefully handle the user moving in and out of the app
- * 3) use a button or trigger of some sort to start the observable, something more in line with typical use
- * 4) ensure that the callbacks are not called if the user moves away from the fragment
+ * Problem:
+ * You have a data source (where that data is potentially expensive to obtain), and you want to
+ * emit this data into a fragment. However, you want to gracefully deal with rotation changes and
+ * not lose any data already emitted.
+ * <p/>
+ * You also want your UI to update accordingly to the data being emitted.
  *
  * @author zsiegel ([email protected])
  */
-public class RetainedFragmentActivityV2 extends Activity {
+public class UIBindingActivity extends Activity {
 
     @Override
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
         requestWindowFeature(Window.FEATURE_INDETERMINATE_PROGRESS);
-        setTitle("Fake API call V2");
-        setContentView(R.layout.retained_fragment_activity_v2);
+        setTitle("UIBinding");
+        setContentView(R.layout.ui_binding_activity);
     }
 
     @SuppressWarnings("ConstantConditions")
-    public static class RetainedFragmentV2 extends Fragment {
+    public static class RetainedBindingFragment extends Fragment {
 
-        private Observable<String> observable;
-        private Subscription subscription = Subscriptions.empty();
         private Button startButton;
-        private boolean progressVisiblity;
+
+        private Observable<String> request;
+        private Subscription requestSubscription = Subscriptions.empty();
 
         // in a production app, you don't want to have JSON parser code in your fragment,
         // but we'll simplify a little here
@@ -60,7 +60,7 @@ public String call(String json) {
             }
         };
 
-        public RetainedFragmentV2() {
+        public RetainedBindingFragment() {
             setRetainInstance(true);
         }
 
@@ -69,7 +69,7 @@ public RetainedFragmentV2() {
          */
         @Override
         public void onPause() {
-            subscription.unsubscribe();
+            requestSubscription.unsubscribe();
             super.onPause();
         }
 
@@ -91,24 +91,21 @@ public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle sa
         public void onViewCreated(final View view, Bundle savedInstanceState) {
             super.onViewCreated(view, savedInstanceState);
 
-            final TextView textView = (TextView)getView().findViewById(android.R.id.text1);
+            final TextView textView = (TextView) getView().findViewById(android.R.id.text1);
 
             startButton = (Button) view.findViewById(R.id.button);
             startButton.setOnClickListener(new View.OnClickListener() {
                 @Override
                 public void onClick(View v) {
                     textView.setText("");
                     start();
-                    startButton.setEnabled(false);
                 }
             });
         }
 
         private void start() {
 
-            progressVisiblity = true;
-
-            observable = SampleObservables
+            request = SampleObservables
                     .fakeApiCall(5000)
                     .map(PARSE_JSON)
                     .observeOn(AndroidSchedulers.mainThread())
@@ -121,22 +118,33 @@ private void start() {
          * We subscribe/re-subscribe here
          */
         private void subscribe() {
-            if (observable != null) {
+            if (request != null) {
+
+                final TextView textView = (TextView) getView().findViewById(android.R.id.text1);
 
-                getActivity().setProgressBarIndeterminateVisibility(progressVisiblity);
+                requestSubscription = request.map(new Func1<String, Boolean>() {
 
-                final TextView textView = (TextView)getView().findViewById(android.R.id.text1);
+                    //Consume the data that comes back and then signal that we are done
+                    @Override
+                    public Boolean call(String s) {
+                        textView.setText(s);
+                        return true;
+                    }
+                }).startWith(false) //Before we receive data our request is not complete
+                  .subscribe(new Action1<Boolean>() {
 
-                subscription = observable.subscribe(new Action1<String>() {
+                    //We update the UI based on the state of the request
                     @Override
-                    public void call(String result) {
-                        textView.setText(result);
-                        progressVisiblity = false;
-                        getActivity().setProgressBarIndeterminateVisibility(progressVisiblity);
-                        startButton.setEnabled(true);
+                    public void call(Boolean completed) {
+                        setRequestInProgress(completed);
                     }
                 });
             }
         }
+
+        private void setRequestInProgress(boolean completed) {
+            getActivity().setProgressBarIndeterminateVisibility(!completed);
+            startButton.setEnabled(completed);
+        }
     }
 }

rxjava-contrib/rxjava-android-samples/samples/src/main/res/layout/retained_fragment_activity_v2.xml renamed to rxjava-contrib/rxjava-android-samples/samples/src/main/res/layout/ui_binding_activity.xml

@@ -8,7 +8,7 @@
             android:tag="retained_fragment_v2"
             android:layout_width="match_parent"
             android:layout_height="match_parent"
-            android:name="com.netflix.rxjava.android.samples.RetainedFragmentActivityV2$RetainedFragmentV2"
+            android:name="com.netflix.rxjava.android.samples.UIBindingActivity$RetainedBindingFragment"
             tools:layout="@layout/retained_fragment" />
 
 </RelativeLayout>