22
22
import static org .mockito .Mockito .never ;
23
23
import static org .mockito .Mockito .times ;
24
24
import static org .mockito .Mockito .verify ;
25
+ import static org .mockito .Mockito .verifyNoMoreInteractions ;
25
26
26
27
import java .util .ArrayList ;
27
28
import java .util .concurrent .atomic .AtomicInteger ;
@@ -116,6 +117,7 @@ private void assertCompletedObserver(Observer<String> observer) {
116
117
verify (observer , never ()).onNext ("four" );
117
118
verify (observer , never ()).onError (any (Throwable .class ));
118
119
verify (observer , times (1 )).onCompleted ();
120
+ verifyNoMoreInteractions (observer );
119
121
}
120
122
121
123
private void assertNeverObserver (Observer <String > observer ) {
@@ -125,6 +127,7 @@ private void assertNeverObserver(Observer<String> observer) {
125
127
verify (observer , never ()).onNext ("four" );
126
128
verify (observer , never ()).onError (any (Throwable .class ));
127
129
verify (observer , times (1 )).onCompleted ();
130
+ verifyNoMoreInteractions (observer );
128
131
}
129
132
130
133
@ Test
@@ -158,6 +161,7 @@ private void assertErrorObserver(Observer<String> observer) {
158
161
verify (observer , times (1 )).onNext ("three" );
159
162
verify (observer , times (1 )).onError (testException );
160
163
verify (observer , never ()).onCompleted ();
164
+ verifyNoMoreInteractions (observer );
161
165
}
162
166
163
167
private void assertNeverErrorObserver (Observer <String > observer ) {
@@ -167,6 +171,7 @@ private void assertNeverErrorObserver(Observer<String> observer) {
167
171
verify (observer , never ()).onNext ("four" );
168
172
verify (observer , times (1 )).onError (any (Throwable .class ));
169
173
verify (observer , never ()).onCompleted ();
174
+ verifyNoMoreInteractions (observer );
170
175
}
171
176
172
177
@ Test
0 commit comments