Fixed test bug and test expectations

Author: akarnokd

src/test/java/rx/internal/operators/OperatorConcatTest.java

@@ -471,7 +471,7 @@ public void unsubscribe() {
 
             @Override
             public boolean isUnsubscribed() {
-                return subscribed;
+                return !subscribed;
             }
 
         };

src/test/java/rx/internal/operators/OperatorReplayTest.java

@@ -607,6 +607,7 @@ public void testIssue2191_SchedulerUnsubscribe() throws Exception {
         verifyObserverMock(mockObserverBeforeConnect, 2, 6);
         verifyObserverMock(mockObserverAfterConnect, 2, 6);
 
+        verify(spiedWorker, times(1)).isUnsubscribed();
         verify(spiedWorker, times(1)).unsubscribe();
         verify(sourceUnsubscribed, times(1)).call();
 
@@ -666,6 +667,7 @@ public void testIssue2191_SchedulerUnsubscribeOnError() throws Exception {
         verifyObserver(mockObserverBeforeConnect, 2, 2, illegalArgumentException);
         verifyObserver(mockObserverAfterConnect, 2, 2, illegalArgumentException);
 
+        verify(spiedWorker, times(1)).isUnsubscribed();
         verify(spiedWorker, times(1)).unsubscribe();
         verify(sourceUnsubscribed, times(1)).call();