1818
1919import static com .google .common .truth .Truth .assertThat ;
2020import static java .util .concurrent .TimeUnit .SECONDS ;
21+ import static org .junit .Assert .fail ;
2122import static org .mockito .ArgumentMatchers .any ;
2223import static org .mockito .ArgumentMatchers .eq ;
2324import static org .mockito .ArgumentMatchers .same ;
3637import io .grpc .Metadata ;
3738import io .grpc .Status ;
3839import io .grpc .StatusException ;
39- import static org .junit .Assert .assertThrows ;
40- import static org .junit .Assert .fail ;
4140import java .lang .reflect .Method ;
4241import java .lang .reflect .Modifier ;
4342import java .util .Arrays ;
@@ -170,8 +169,8 @@ public void startThenSetCall() {
170169 @ Test
171170 @ SuppressWarnings ("unchecked" )
172171 public void cancelThenSetCall () {
173- DelayedClientCall <String , Integer > delayedClientCall = new DelayedClientCall <>(
174- callExecutor , fakeClock .getScheduledExecutorService (), null );
172+ DelayedClientCall <String , Integer > delayedClientCall =
173+ new DelayedClientCall <>( callExecutor , fakeClock .getScheduledExecutorService (), null );
175174 delayedClientCall .start (listener , new Metadata ());
176175 delayedClientCall .request (1 );
177176 delayedClientCall .cancel ("cancel" , new StatusException (Status .CANCELLED ));
@@ -186,8 +185,8 @@ public void cancelThenSetCall() {
186185 @ Test
187186 @ SuppressWarnings ("unchecked" )
188187 public void setCallThenCancel () {
189- DelayedClientCall <String , Integer > delayedClientCall = new DelayedClientCall <>(
190- callExecutor , fakeClock .getScheduledExecutorService (), null );
188+ DelayedClientCall <String , Integer > delayedClientCall =
189+ new DelayedClientCall <>( callExecutor , fakeClock .getScheduledExecutorService (), null );
191190 delayedClientCall .start (listener , new Metadata ());
192191 delayedClientCall .request (1 );
193192 Runnable r = delayedClientCall .setCall (mockRealCall );
0 commit comments