remove usage of AsyncUtils

Author: Petikoch

src/main/java/ch/petikoch/examples/mvvm_rxjava/example5a/Example_5a_Model.java

@@ -17,24 +17,25 @@
 
 import ch.petikoch.examples.mvvm_rxjava.datatypes.NameFirstname;
 import ch.petikoch.examples.mvvm_rxjava.rxjava_mvvm.FinishedIndicator;
-import ch.petikoch.examples.mvvm_rxjava.utils.AsyncUtils;
 import ch.petikoch.examples.mvvm_rxjava.utils.SysOutUtils;
 import net.jcip.annotations.ThreadSafe;
 import rx.Single;
+import rx.schedulers.Schedulers;
 
 @ThreadSafe
 class Example_5a_Model {
 
     public Single<FinishedIndicator> createAccount(NameFirstname nameFirstname) {
-        return AsyncUtils.<FinishedIndicator>executeAsync(() -> {
+        return Single.fromCallable(() -> {
             try {
                 SysOutUtils.sysout("Processing: " + nameFirstname.toString());
                 Thread.sleep(5000);    // = Simulation of a "very slow" backend
                 SysOutUtils.sysout("Finished: " + nameFirstname.toString());
             } catch (InterruptedException e) {
                 SysOutUtils.sysout("Interrupted (=cancelled) -> good!");
             }
-        });
+            return FinishedIndicator.INSTANCE;
+        }).subscribeOn(Schedulers.io());
     }
 
 }

src/main/java/ch/petikoch/examples/mvvm_rxjava/example5a/Example_5a_ViewModel.java

@@ -70,7 +70,10 @@ private void wireInternally() {
     public void connectTo(final Example_5a_Model model) {
         onEventFrom(vm2m_nameFirstname).executeAsync(nameFirstname -> {
 
-            Single.merge(model.createAccount(nameFirstname), v2vm_cancelButtonEvents.first().toSingle())
+            Single.merge(
+                    model.createAccount(nameFirstname),
+                    v2vm_cancelButtonEvents.first().toSingle()
+            )
                     .toBlocking()
                     .first();