Removed some unused code, fixed some (Eclipse) warnings

Author: jmhofer

rxjava-core/src/main/java/rx/concurrency/SleepingAction.java

@@ -15,8 +15,6 @@
  */
 package rx.concurrency;
 
-import java.util.concurrent.TimeUnit;
-
 import rx.Scheduler;
 import rx.Subscription;
 import rx.util.functions.Func2;

rxjava-core/src/main/java/rx/operators/OperationFinally.java

@@ -15,7 +15,6 @@
  */
 package rx.operators;
 
-import static org.junit.Assert.*;
 import static org.mockito.Mockito.*;
 
 import org.junit.Before;
@@ -24,7 +23,6 @@
 import rx.Observable;
 import rx.Observer;
 import rx.Subscription;
-import rx.util.AtomicObservableSubscription;
 import rx.util.functions.Action0;
 import rx.util.functions.Func1;
 
@@ -103,19 +101,24 @@ public void onNext(T args) {
     public static class UnitTest {
         private Action0 aAction0;
         private Observer<String> aObserver;
+        
+        @SuppressWarnings("unchecked") // mocking has to be unchecked, unfortunately
         @Before
         public void before() {
             aAction0 = mock(Action0.class);
             aObserver = mock(Observer.class);
         }
+        
         private void checkActionCalled(Observable<String> input) {
             Observable.create(finallyDo(input, aAction0)).subscribe(aObserver);
             verify(aAction0, times(1)).call();
         }
+        
         @Test
         public void testFinallyCalledOnComplete() {
             checkActionCalled(Observable.toObservable(new String[] {"1", "2", "3"}));
         }
+        
         @Test
         public void testFinallyCalledOnError() {
             checkActionCalled(Observable.<String>error(new RuntimeException("expected")));

rxjava-core/src/main/java/rx/operators/OperationMulticast.java

@@ -98,6 +98,7 @@ public void testMulticast() {
             ConnectableObservable<String> multicasted = OperationMulticast.multicast(source,
                     PublishSubject.<String>create());
 
+            @SuppressWarnings("unchecked")
             Observer<String> observer = mock(Observer.class);
             multicasted.subscribe(observer);
 
@@ -125,6 +126,7 @@ public void testMulticastConnectTwice() {
             ConnectableObservable<String> multicasted = OperationMulticast.multicast(source,
                     PublishSubject.<String>create());
 
+            @SuppressWarnings("unchecked")
             Observer<String> observer = mock(Observer.class);
             multicasted.subscribe(observer);
 
@@ -149,6 +151,7 @@ public void testMulticastDisconnect() {
             ConnectableObservable<String> multicasted = OperationMulticast.multicast(source,
                     PublishSubject.<String>create());
 
+            @SuppressWarnings("unchecked")
             Observer<String> observer = mock(Observer.class);
             multicasted.subscribe(observer);
 
@@ -226,11 +229,6 @@ public void sendOnNext(String value) {
                 observer.onNext(value);
             }
 
-            /* used to simulate subscription */
-            public void sendOnError(Exception e) {
-                observer.onError(e);
-            }
-
             @Override
             public Subscription subscribe(final Observer<String> observer) {
                 this.observer = observer;

rxjava-core/src/main/java/rx/operators/OperationToObservableList.java

@@ -104,6 +104,7 @@ public void testListMultipleObservers() {
             Observer<List<String>> o1 = mock(Observer.class);
             observable.subscribe(o1);
 
+            @SuppressWarnings("unchecked")
             Observer<List<String>> o2 = mock(Observer.class);
             observable.subscribe(o2);
 

rxjava-core/src/test/java/rx/concurrency/TestSchedulers.java

@@ -16,7 +16,6 @@
 package rx.concurrency;
 
 import static org.junit.Assert.*;
-import static org.mockito.Mockito.*;
 
 import java.util.Date;
 import java.util.concurrent.CountDownLatch;
@@ -321,9 +320,6 @@ public Subscription call(Scheduler scheduler, BooleanSubscription cancel) {
             }
         });
 
-        @SuppressWarnings("unchecked")
-        Observer<Integer> o = mock(Observer.class);
-
         final AtomicInteger count = new AtomicInteger();
         final AtomicBoolean completed = new AtomicBoolean(false);
         Subscription subscribe = obs.subscribe(new Observer<Integer>() {