Erreur lors de la création d'Observer dans RxAndroid

Question

Je fais un exemple en utilisant RxAndroid comme indiqué ci-dessous dans le code. mais studio Android donne l'erreur suivante:

incompatible types 
required: io.reactivex.observable <String> 
found: void 

S'il vous plaît laissez-moi savoir comment corriger cette erreur

Code:

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() { 
     @Override 
     public void subscribe(ObservableEmitter<String> e) throws Exception { 
      e.onNext("onNext"); 
      e.onComplete(); 

     } 
    }).subscribe(new Observer<String>() { 
     @Override 
     public void onSubscribe(Disposable d) { 

     } 

     @Override 
     public void onNext(String value) { 

     } 

     @Override 
     public void onError(Throwable e) { 

     } 

     @Override 
     public void onComplete() { 

     } 
    }); 

Answer 1

Divisez la création et abonnez-vous dans différentes déclarations:

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() { 
    @Override 
    public void subscribe(ObservableEmitter<String> e) throws Exception { 
     e.onNext("onNext"); 
     e.onComplete(); 

    } 
}); 

observable.subscribe(new Observer<String>() { 
    @Override 
    public void onSubscribe(Disposable d) { 

    } 

    @Override 
    public void onNext(String value) { 

    } 

    @Override 
    public void onError(Throwable e) { 

    } 

    @Override 
    public void onComplete() { 

    } 
});