d'expression rxjava de retrolambda au classique

Question

J'utilise l'expression retrolambda

_rxBus = getRxBusSingleton(); 
    _disposables = new CompositeDisposable(); 

    ConnectableFlowable<Object> tapEventEmitter = _rxBus.asFlowable().publish(); 

    _disposables 
      .add(tapEventEmitter.subscribe(event -> { 

      if (event instanceof EmployeeMvvmActivity.TapEvent) { 
       _showTapText(); 
      } 

      })); 

Tout beau travail. En raison de tests Roboelectric j'ai besoin de convertir l'expression retrolambda classique. J'ai essayé

_disposables.add(tapEventEmitter.subscribe(new Action1<Object>() { 
     @Override 
     public void call(Object event) { 
      if (event instanceof EmployeeMvvmActivity.TapEvent) { 
       _showTapText(); 
      } 
     } 
    })); 

J'ai obtenu l'erreur ne peut pas résoudre méthode "subscribe (anonyme rx.functions.Action1 (java.lang.Object).

Answer 1

Le Action1 vient de Rx1 pendant que vous utilisez Rx2 . Une exception a eu lieu dans le compilateur (1.8 au lieu de cela, vous devez utiliser l'interface Consumer.

_disposables.add(tapEventEmitter.subscribe(new Consumer<Object>() { 
    @Override 
    public void accept(Object event) { 
     if (event instanceof EmployeeMvvmActivity.TapEvent) { 
      _showTapText(); 
     } 
    } 
}));