このような何かすることはできなかったrxJavaの1.xではrxJava 2

Question

に同じ加入者登録：）

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

GetNewObservableを（私は同じアプローチを見つけることができないもObservable<Foo>

を返しますrxJava 2. ObservableオブジェクトにEmitterまたはObservableEmitterを受け入れるsubscribeメソッドはありません。

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

しかし

rxJava 1に感謝のようないくつかのより簡単な方法がある場合、私は思ったんだけど：私はこのような何かを行うことができたとします。

Answer 1

1）あなたはコメントで説明したものを実行する1つの方法：

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

2）それを行う別の方法：

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

3）さらに別の方法（一回のみの権限を確認してください）： ）

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

4）もう一つの（最も反応性：

あなたのようにリファクタリングすることができます

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

：

askForPermission().andThen(getNewObservable())