1.x: Single.flatMapCompletable

src/main/java/rx/Single.java

@@ -1396,6 +1396,25 @@ public final <R> Observable<R> flatMapObservable(Func1<? super T, ? extends Obse
         return Observable.merge(asObservable(map(func)));
     }
 
+    public final Completable flatMapCompletable(final Func1<? super T, ? extends Completable> func) {
+        return Completable.create(new Completable.CompletableOnSubscribe() {
+            @Override
+            public void call(final Completable.CompletableSubscriber completableSubscriber) {
+                subscribe(new SingleSubscriber<T>() {
+                    @Override
+                    public void onSuccess(final T value) {
+                        func.call(value).subscribe(completableSubscriber);
+                    }
+
+                    @Override
+                    public void onError(final Throwable error) {
+                        completableSubscriber.onError(error);
+                    }
+                });
+            }
+        });
+    }
+
     /**
      * Returns a Single that applies a specified function to the item emitted by the source Single and
      * emits the result of this function application.

src/test/java/rx/SingleTest.java

@@ -2005,4 +2005,32 @@ public Single<Integer> call(Integer v) {
         assertFalse("Observers present?!", ps.hasObservers());
     }
 
+    @Test
+    public void flatMapCompletableComplete() {
+        TestSubscriber testSubscriber = new TestSubscriber();
+
+        Single.just(1).flatMapCompletable(new Func1<Integer, Completable>() {
+            @Override
+            public Completable call(final Integer integer) {
+                return Completable.complete();
+            }
+        }).subscribe(testSubscriber);
+
+        testSubscriber.assertCompleted();
+    }
+
+    @Test
+    public void flatMapCompletableError() {
+        final RuntimeException error = new RuntimeException("some error");
+        TestSubscriber testSubscriber = new TestSubscriber();
+
+        Single.just(1).flatMapCompletable(new Func1<Integer, Completable>() {
+            @Override
+            public Completable call(final Integer integer) {
+                return Completable.error(error);
+            }
+        }).subscribe(testSubscriber);
+
+        testSubscriber.assertError(error);
+    }
 }