@@ -14,8 +14,8 @@ public class NettyResponseFutureTest {
14
14
15
15
@ Test
16
16
public void testCancel () {
17
- AsyncHandler asyncHandler = mock (AsyncHandler .class );
18
- NettyResponseFuture nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
17
+ AsyncHandler <?> asyncHandler = mock (AsyncHandler .class );
18
+ NettyResponseFuture <?> nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
19
19
boolean result = nettyResponseFuture .cancel (false );
20
20
verify (asyncHandler ).onThrowable (anyObject ());
21
21
assertTrue (result , "Cancel should return true if the Future was cancelled successfully" );
@@ -24,8 +24,8 @@ public void testCancel() {
24
24
25
25
@ Test
26
26
public void testCancelOnAlreadyCancelled () {
27
- AsyncHandler asyncHandler = mock (AsyncHandler .class );
28
- NettyResponseFuture nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
27
+ AsyncHandler <?> asyncHandler = mock (AsyncHandler .class );
28
+ NettyResponseFuture <?> nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
29
29
nettyResponseFuture .cancel (false );
30
30
boolean result = nettyResponseFuture .cancel (false );
31
31
assertFalse (result , "cancel should return false for an already cancelled Future" );
@@ -34,38 +34,39 @@ public void testCancelOnAlreadyCancelled() {
34
34
35
35
@ Test (expectedExceptions = CancellationException .class )
36
36
public void testGetContentThrowsCancellationExceptionIfCancelled () throws InterruptedException , ExecutionException {
37
- AsyncHandler asyncHandler = mock (AsyncHandler .class );
38
- NettyResponseFuture nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
37
+ AsyncHandler <?> asyncHandler = mock (AsyncHandler .class );
38
+ NettyResponseFuture <?> nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
39
39
nettyResponseFuture .cancel (false );
40
40
nettyResponseFuture .get ();
41
41
fail ("A CancellationException must have occurred by now as 'cancel' was called before 'get'" );
42
42
}
43
43
44
44
@ Test
45
45
public void testGet () throws Exception {
46
- AsyncHandler asyncHandler = mock (AsyncHandler .class );
46
+ @ SuppressWarnings ("unchecked" )
47
+ AsyncHandler <Object > asyncHandler = mock (AsyncHandler .class );
47
48
Object value = new Object ();
48
49
when (asyncHandler .onCompleted ()).thenReturn (value );
49
- NettyResponseFuture nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
50
+ NettyResponseFuture <?> nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
50
51
nettyResponseFuture .done ();
51
52
Object result = nettyResponseFuture .get ();
52
53
assertEquals (result , value , "The Future should return the value given by asyncHandler#onCompleted" );
53
54
}
54
55
55
56
@ Test (expectedExceptions = ExecutionException .class )
56
57
public void testGetThrowsExceptionThrownByAsyncHandler () throws Exception {
57
- AsyncHandler asyncHandler = mock (AsyncHandler .class );
58
+ AsyncHandler <?> asyncHandler = mock (AsyncHandler .class );
58
59
when (asyncHandler .onCompleted ()).thenThrow (new RuntimeException ());
59
- NettyResponseFuture nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
60
+ NettyResponseFuture <?> nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
60
61
nettyResponseFuture .done ();
61
62
nettyResponseFuture .get ();
62
63
fail ("An ExecutionException must have occurred by now as asyncHandler threw an exception in 'onCompleted'" );
63
64
}
64
65
65
66
@ Test (expectedExceptions = ExecutionException .class )
66
67
public void testGetThrowsExceptionOnAbort () throws InterruptedException , ExecutionException {
67
- AsyncHandler asyncHandler = mock (AsyncHandler .class );
68
- NettyResponseFuture nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
68
+ AsyncHandler <?> asyncHandler = mock (AsyncHandler .class );
69
+ NettyResponseFuture <?> nettyResponseFuture = new NettyResponseFuture <>(null , asyncHandler , null , 3 , null , null );
69
70
nettyResponseFuture .abort (new RuntimeException ());
70
71
nettyResponseFuture .get ();
71
72
fail ("An ExecutionException must have occurred by now as 'abort' was called before 'get'" );
0 commit comments