はAsyncOnSubscribeでコンパイルエラー解決できません

Question

Observable<ScanResult> scanResultStream(UUID uuid) { 
    return Observable.create(new AsyncOnSubscribe<Boolean, Subscriber<ScanResult>>() { 
     @Override 
     Boolean next(Boolean previousState, long requested, Observer<Observable<Subscriber<ScanResult>>> sub) { 
      return true; 
     } 
    }); 
} 

私は考えることができるが、これはコンパイルするために取得することはできませんし、いつものようにRxJavaのドキュメントはありません非常に有用である、と私はより良い例や説明を見つけることができないすべてのものを試してみました。

問題は、ドキュメントが、「このと互換性がありますSubscriber Sの種類」であると言うAsyncOnSubscribeための第二のコンストラクタの型パラメータ<T>、であるように見えます。これを文字通り取ると、これは<Subscriber<ScanResult>>であるべきだと思いますが、これはうまくいきません。クラスが抽象宣言されなければならない、またはを実装する必要がありますが、とすると、私のメソッドシグネチャはnext(Boolean previousState, long requested, Observer<Observable<Subscriber<ScanResult>>> obs)でなければなりませんが、メッセージは 'メソッドがスーパークラスからメソッドをオーバーライドしません'というメッセージを生成します。

また、未チェックの割り当て： 'rx.Observable<T>〜rx.Observable<com.polidea.rxandroidble.scan.ScanResult'が表示されています。

私がAsyncOnSubscribeの明確な説明を見つけることができれば、おそらく私はこれを理解することができました。 （これはすべて私がObservable.create(Observable.OnSubscribe)を使用したい時に始めたが、それが廃止されましたが分かった。）

Answer 1

環境：

RxJava 1.3.4

• これは間違っている：オブザーバー>>サブ
• IMP

結果がありません

Observable<ScanResult> scanResultStream(UUID uuid) { 
    Observable<ScanResult> scanResultObservable = 
     Observable.create(
      new AsyncOnSubscribe<Boolean, ScanResult>() { 
       @Override 
       protected Boolean generateState() { 
       return null; 
       } 

       @Override 
       protected Boolean next(
        Boolean state, 
        long requested, 
        Observer<Observable<? extends ScanResult>> observer) { 
       return null; 
       } 
      }); 

    return scanResultObservable; 
    }