@@ -44,8 +44,8 @@ class Example_6_ViewModel implements IViewModel<Example_6_Model> {
44
44
public final PublishSubject <ActionEvent > v2vm_cancelButtonEvents = PublishSubject .create ();
45
45
public final BehaviorSubject <Boolean > vm2v_cancelButtonEnabled = BehaviorSubject .create (false /* initial state */ );
46
46
47
- public final BehaviorSubject <String > vm2v_resultat1 = BehaviorSubject .create ();
48
- public final BehaviorSubject <String > vm2v_resultat2 = BehaviorSubject .create ();
47
+ public final BehaviorSubject <String > vm2v_result1 = BehaviorSubject .create ();
48
+ public final BehaviorSubject <String > vm2v_result2 = BehaviorSubject .create ();
49
49
50
50
public final BehaviorSubject <NameFirstname > vm2m_nameFirstname = BehaviorSubject .create ();
51
51
@@ -70,41 +70,41 @@ private void wireInternally() {
70
70
.subscribe (vm2v_submitButtonEnabled );
71
71
72
72
Observable .merge (v2vm_name , v2vm_firstname ).subscribe (s -> {
73
- vm2v_resultat1 .onNext ("Ready" );
74
- vm2v_resultat2 .onNext ("Also ready" );
73
+ vm2v_result1 .onNext ("Ready" );
74
+ vm2v_result2 .onNext ("Also ready" );
75
75
});
76
76
}
77
77
78
78
@ Override
79
79
public void connectTo (final Example_6_Model model ) {
80
80
onEventFrom (vm2m_nameFirstname ).executeAsync (nameFirstname -> {
81
81
82
- vm2v_resultat1 .onNext ("Creating acount..." );
83
- vm2v_resultat2 .onNext ("Sending email..." );
82
+ vm2v_result1 .onNext ("Creating acount..." );
83
+ vm2v_result2 .onNext ("Sending email..." );
84
84
85
85
final Single <FinishedIndicator > createAccountResult = model .createAcount (nameFirstname );
86
86
createAccountResult .toObservable ()
87
87
.first ()
88
88
.takeUntil (v2vm_cancelButtonEvents )
89
89
.subscribe (
90
- finishedIndicator -> vm2v_resultat1 .onNext ("Acount created for " + nameFirstname .getName () + " " + nameFirstname .getFirstname ())
90
+ finishedIndicator -> vm2v_result1 .onNext ("Acount created for " + nameFirstname .getName () + " " + nameFirstname .getFirstname ())
91
91
);
92
92
v2vm_cancelButtonEvents
93
93
.first ()
94
94
.takeUntil (createAccountResult .toObservable ())
95
- .subscribe (actionEvent -> vm2v_resultat1 .onNext ("Aborted" ));
95
+ .subscribe (actionEvent -> vm2v_result1 .onNext ("Aborted" ));
96
96
97
97
final Single <FinishedIndicator > sendEmailResult = model .sendEmail (nameFirstname );
98
98
sendEmailResult .toObservable ()
99
99
.first ()
100
100
.takeUntil (v2vm_cancelButtonEvents )
101
101
.subscribe (
102
- finishedIndicator -> vm2v_resultat2 .onNext ("Email sent to " + nameFirstname .getName () + " " + nameFirstname .getFirstname ())
102
+ finishedIndicator -> vm2v_result2 .onNext ("Email sent to " + nameFirstname .getName () + " " + nameFirstname .getFirstname ())
103
103
);
104
104
v2vm_cancelButtonEvents
105
105
.first ()
106
106
.takeUntil (sendEmailResult .toObservable ())
107
- .subscribe (actionEvent -> vm2v_resultat2 .onNext ("Aborted" ));
107
+ .subscribe (actionEvent -> vm2v_result2 .onNext ("Aborted" ));
108
108
109
109
final Single <FinishedIndicator > bothFinished = Single .zip (
110
110
createAccountResult ,
0 commit comments