@Test
public void testObservableLoaded() throws Exception {

    TestSubscriber<Integer> subscriber = new TestSubscriber<>();
    Observable.just(1)
            .compose(RxUtils.<Integer>async())
            .compose(mLifecycleHandler.<Integer>load(2))
            .subscribe(subscriber);
    subscriber.assertValue(1);
    subscriber.assertCompleted();
}