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) {
83
83
vm2v_resultat2 .onNext ("Sending email..." );
84
84
85
85
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
+ );
88
92
v2vm_cancelButtonEvents .first ().takeUntil (createAccountResult .toObservable ()).subscribe (actionEvent -> vm2v_resultat1 .onNext ("Aborted" ));
89
93
90
94
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
+ );
93
101
v2vm_cancelButtonEvents .first ().takeUntil (sendEmailResult .toObservable ()).subscribe (actionEvent -> vm2v_resultat2 .onNext ("Aborted" ));
94
102
95
103
final Single <FinishedIndicator > bothFinished = Single .zip (
You can’t perform that action at this time.
0 commit comments