added another test against multiple staggered subscribers

Author: Joachim Hofer

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

@@ -32,7 +32,6 @@
 import rx.Subscription;
 import rx.concurrency.Schedulers;
 import rx.concurrency.TestScheduler;
-import rx.observables.ConnectableObservable;
 import rx.subscriptions.Subscriptions;
 import rx.util.functions.Action0;
 
@@ -165,5 +164,46 @@ public void testWithMultipleSubscribersStartingAtSameTime() {
             verify(observer2, times(1)).onCompleted();
             verify(observer2, never()).onError(any(Throwable.class));
         }
+
+        @Test
+        public void testWithMultipleStaggeredSubscribers() {
+            Observable<Long> w = Observable.create(OperationInterval.interval(1, TimeUnit.SECONDS, scheduler));
+            Subscription sub1 = w.subscribe(observer);
+
+            verify(observer, never()).onNext(anyLong());
+            
+            scheduler.advanceTimeTo(2, TimeUnit.SECONDS);
+            Subscription sub2 = w.subscribe(observer2);
+            
+            InOrder inOrder1 = inOrder(observer);
+            inOrder1.verify(observer, times(1)).onNext(0L);
+            inOrder1.verify(observer, times(1)).onNext(1L);
+            inOrder1.verify(observer, never()).onNext(2L);
+            
+            verify(observer, never()).onCompleted();
+            verify(observer, never()).onError(any(Throwable.class));
+            verify(observer2, never()).onNext(anyLong());
+
+            scheduler.advanceTimeTo(4, TimeUnit.SECONDS);
+            
+            inOrder1.verify(observer, times(1)).onNext(2L);
+            inOrder1.verify(observer, times(1)).onNext(3L);
+            inOrder1.verify(observer, never()).onNext(4L);
+            
+            InOrder inOrder2 = inOrder(observer2);
+            inOrder2.verify(observer2, times(1)).onNext(0L);
+            inOrder2.verify(observer2, times(1)).onNext(1L);
+            
+            sub1.unsubscribe();
+            sub2.unsubscribe();
+
+            inOrder1.verify(observer, never()).onNext(anyLong());
+            inOrder1.verify(observer, times(1)).onCompleted();
+            verify(observer, never()).onError(any(Throwable.class));
+
+            inOrder2.verify(observer2, never()).onNext(2L);
+            inOrder2.verify(observer2, times(1)).onCompleted();
+            verify(observer2, never()).onError(any(Throwable.class));
+        }
     }
 }