@Test
public void testCreateUnsubscribed() throws Exception {

    Subscription subscription = RxJavaCreate.observableWithCreate()
            .subscribeOn(Schedulers.newThread())
            .subscribe(System.out::println);
    subscription.unsubscribe();
}