File tree Expand file tree Collapse file tree 1 file changed +12
-4
lines changed
src/main/java/ch/petikoch/examples/mvvm_rxjava/example6 Expand file tree Collapse file tree 1 file changed +12
-4
lines changed Original file line number Diff line number Diff line change @@ -83,13 +83,21 @@ public void connectTo(final Example_6_Model model) {
8383 vm2v_resultat2 .onNext ("Sending email..." );
8484
8585 final Single <FinishedIndicator > createAccountResult = model .createAcount (nameFirstname );
86- createAccountResult .toObservable ().first ().takeUntil (v2vm_cancelButtonEvents ).subscribe (
87- finishedIndicator -> vm2v_resultat1 .onNext ("Acount created for " + nameFirstname .getName () + " " + nameFirstname .getFirstname ()));
86+ createAccountResult .toObservable ()
87+ .first ()
88+ .takeUntil (v2vm_cancelButtonEvents )
89+ .subscribe (
90+ finishedIndicator -> vm2v_resultat1 .onNext ("Acount created for " + nameFirstname .getName () + " " + nameFirstname .getFirstname ())
91+ );
8892 v2vm_cancelButtonEvents .first ().takeUntil (createAccountResult .toObservable ()).subscribe (actionEvent -> vm2v_resultat1 .onNext ("Aborted" ));
8993
9094 final Single <FinishedIndicator > sendEmailResult = model .sendEmail (nameFirstname );
91- sendEmailResult .toObservable ().first ().takeUntil (v2vm_cancelButtonEvents ).subscribe (
92- finishedIndicator -> vm2v_resultat2 .onNext ("Email sent to " + nameFirstname .getName () + " " + nameFirstname .getFirstname ()));
95+ sendEmailResult .toObservable ()
96+ .first ()
97+ .takeUntil (v2vm_cancelButtonEvents )
98+ .subscribe (
99+ finishedIndicator -> vm2v_resultat2 .onNext ("Email sent to " + nameFirstname .getName () + " " + nameFirstname .getFirstname ())
100+ );
93101 v2vm_cancelButtonEvents .first ().takeUntil (sendEmailResult .toObservable ()).subscribe (actionEvent -> vm2v_resultat2 .onNext ("Aborted" ));
94102
95103 final Single <FinishedIndicator > bothFinished = Single .zip (
You can’t perform that action at this time.
0 commit comments