Update README.md

ragnraok · Nov 10, 2015 · a36f6c4 · a36f6c4
1 parent bed8a04
commit a36f6c4
Showing 1 changed file with 26 additions and 17 deletions.
diff --git a/README.md b/README.md
@@ -12,25 +12,34 @@ RxCameraConfig config = RxCameraConfigChooser.obtain().
                 setHandleSurfaceEvent(true).
                 get();
 Log.d(TAG, "config: " + config);
-RxCamera.open(this, config).subscribe(new Subscriber<RxCamera>() {
-      @Override
-      public void onCompleted() {
-
-      }
+RxCamera.open(this, config).flatMap(new Func1<RxCamera, Observable<RxCamera>>() {
+        @Override
+        public Observable<RxCamera> call(RxCamera rxCamera) {
+            camera = rxCamera;
+            return rxCamera.bindTexture(textureView);
+        }
+    }).flatMap(new Func1<RxCamera, Observable<RxCamera>>() {
+        @Override
+        public Observable<RxCamera> call(RxCamera rxCamera) {
+          return rxCamera.startPreview();
+        }
+    }).subscribe(new Subscriber<RxCamera>() {
+        @Override
+        public void onCompleted() {
+            Log.d(TAG, "onCompleted");
+        }
 
-      @Override
-      public void onError(Throwable e) {
-        Log.d(TAG, "open camera failed: " + e.getMessage());
-      }
+        @Override
+        public void onError(Throwable e) {
+            Log.e(TAG, "error: " + e.getMessage());
+        }
 
-      @Override
-      public void onNext(RxCamera rxCamera) {
-          Log.d(TAG, "open camera success: " + rxCamera.toString());
-          camera = rxCamera;
-          camera.bindTexture(textureView);
-          camera.startPreview();
-      }
-});
+        @Override
+        public void onNext(RxCamera rxCamera) {
+            Log.d(TAG, "success: " + rxCamera);
+        }
+    });
+}
 ```
 
 Still under heavily development