Upgrade rxjava 1.2.1

Author: slandelle

extras/rxjava/pom.xml

@@ -12,7 +12,7 @@
         <dependency>
             <groupId>io.reactivex</groupId>
             <artifactId>rxjava</artifactId>
-            <version>1.0.14</version>
+            <version>1.2.1</version>
         </dependency>
     </dependencies>
 </project>

extras/rxjava/src/test/java/org/asynchttpclient/extras/rxjava/single/AsyncHttpSingleTest.java

@@ -66,6 +66,7 @@ public void testFailsOnNullHandlerSupplier() {
     @Test(groups = "standalone")
     public void testSuccessfulCompletion() throws Exception {
 
+        @SuppressWarnings("unchecked")
         final AsyncHandler<Object> handler = mock(AsyncHandler.class);
         when(handler.onCompleted()).thenReturn(handler);
 
@@ -106,6 +107,7 @@ public void testSuccessfulCompletion() throws Exception {
     @Test(groups = "standalone")
     public void testSuccessfulCompletionWithProgress() throws Exception {
 
+        @SuppressWarnings("unchecked")
         final ProgressAsyncHandler<Object> handler = mock(ProgressAsyncHandler.class);
         when(handler.onCompleted()).thenReturn(handler);
         final InOrder inOrder = inOrder(handler);
@@ -171,6 +173,7 @@ public void testNewRequestForEachSubscription() throws Exception {
     public void testErrorPropagation() throws Exception {
 
         final RuntimeException expectedException = new RuntimeException("expected");
+        @SuppressWarnings("unchecked")
         final AsyncHandler<Object> handler = mock(AsyncHandler.class);
         when(handler.onCompleted()).thenReturn(handler);
         final InOrder inOrder = inOrder(handler);
@@ -214,6 +217,7 @@ public void testErrorPropagation() throws Exception {
     public void testErrorInOnCompletedPropagation() throws Exception {
 
         final RuntimeException expectedException = new RuntimeException("expected");
+        @SuppressWarnings("unchecked")
         final AsyncHandler<Object> handler = mock(AsyncHandler.class);
         when(handler.onCompleted()).thenThrow(expectedException);
 
@@ -243,6 +247,7 @@ public void testErrorInOnThrowablePropagation() throws Exception {
 
         final RuntimeException processingException = new RuntimeException("processing");
         final RuntimeException thrownException = new RuntimeException("thrown");
+        @SuppressWarnings("unchecked")
         final AsyncHandler<Object> handler = mock(AsyncHandler.class);
         doThrow(thrownException).when(handler).onThrowable(processingException);
 
@@ -296,6 +301,7 @@ public State onStatusReceived(HttpResponseStatus status) {
 
     @Test(groups = "standalone")
     public void testUnsubscribe() throws Exception {
+        @SuppressWarnings("unchecked")
         final AsyncHandler<Object> handler = mock(AsyncHandler.class);
         final Future<?> future = mock(Future.class);
         final AtomicReference<AsyncHandler<?>> bridgeRef = new AtomicReference<>();