source: class RxLoaderTest {
  
      @Rule
      public RxSchedulersTestRule mRule;
      private LifecycleHandler mLifecycleHandler;
  
      @Test
      public void testRestartCreatesNewSubscription() throws Exception {
  
target:         Observable<Integer> observable = Observable.just(6, 8, 10);
  
          TestSubscriber<Integer> testSubscriber1 = new TestSubscriber<>();
          TestSubscriber<Integer> testSubscriber2 = new TestSubscriber<>();
  
          observable
                  .compose(mLifecycleHandler.<Integer>load(7))
                  .subscribe(testSubscriber1);
          testSubscriber1.assertValues(6, 8, 10);
          testSubscriber1.assertCompleted();
  
          observable
                  .compose(mLifecycleHandler.<Integer>reload(7))
                  .subscribe(testSubscriber2);
  
          testSubscriber2.assertValues(6, 8, 10);
          testSubscriber2.assertCompleted();
      }
  
  }