Abonnez-vous au même abonné 1.x rxJava il était possible rxJava 2

Question

faire quelque chose comme ceci:

Observable.<Foo>create(subscriber -> { 
    ... 
    getNewObservable().subscribe(Subscribers.wrap(subscriber)); 
}) 

GetNewObservable() retour aussi Observable<Foo>

Je ne trouve pas la même approche dans rxJava 2. Il n'y a pas de méthode d'abonnement acceptant Emitter ou ObservableEmitter sur un objet Observable. Je suppose que je peux faire quelque chose comme ceci:

Observable.<Foo>create((ObservableEmitter<Foo> emitter) -> { 
    ... 
    getNewObservable().subscribe(emitter::onNext, emitter::onError, emitter::onComplete); 
}) 

Mais je me demande s'il y a une manière plus simple comme dans rxJava 1.

Merci.

Answer 1

1) Une façon de faire ce que vous avez décrit dans les commentaires:

Observable.interval(...) 
    .map(n -> { 
      if (!permissionGranted) 
       throw new AccessDeniedException(); 
      ... // do work 
      return result; 
     }) 

2) Une autre façon de le faire:

Observable.interval(...) 
    .flatMap(n -> { 
      if (permissionGranted) { 
       ... // do work 
       return Observable.just(result); 
      } else { 
       return Observable.error(new AccessDeniedException()); 
      } 
     }) 

3) Encore une autre façon (vérifier l'autorisation une seule fois):

Observable.defer(() -> { 
      if (permissionGranted) { 
       return Observable.interval(...) 
        .map(n -> { 
         ... // do work 
         return result; 
        }); 
      } else { 
       return Observable.error(new AccessDeniedException()); 
      } 
     }) 

4) Un plus (le plus réactif ):

Completable.fromCallable(() -> { 
      if (!permissionGranted) 
       throw new AccessDeniedException(); 
      return true; // returned value does not matter 
     }) 
    .andThen(Observable.interval(...) 
        .map(n -> { 
         ... // do work 
         return result; 
        }) 
     ) 

que vous pouvez factoriser comme:

askForPermission().andThen(getNewObservable())