如何知道 observable emit 是否是缓存的 BehaviourSubject 值？

Question

我使用 BehaviourRelay 作为源 observable，我喜欢它会在订阅时发出最后一个缓存的值，所以我不需要手动调用 showPlayingState(mPlayStateManager.getCurrentState())。

但是，当我想对订阅中的动画做出反应时，这会带来一个问题，因为我不想在这个缓存的发出时运行动画，当我订阅 onCreate 时会发出，UI 应该只是跳转到不动画的状态它。动画应该只在“新鲜”发射的情况下运行

这至少对我来说是一个相当常见的用例，但我无法在 rx 中弄清楚它

class Activity {

   PlayStateManager mPlayStateManager;
   Button mButton;

   void onCreate(SavedinstanceState state) {
      mPlayStateManager.playState()
        .subscribe(state -> {
           switch(state) {
            case PlayState.PLAYING:
                showPlayingState(true, ???);
                break;
            case PlayState.PAUSED:
                showPlayingState(false, ???);
                break;
           }
        }
   }

   void showPlayingState(boolean isPlay, boolean animate) {
     if(!animate) {
         mButton.setText(isPlay ? "Playing" : "Paused");
     } else {
         mButton.animate()
           .rotate(360)
           .onAnimationEnd(() -> {
              mButton.setText(isPlay ? "Playing" : "Paused");
           })
      }
   }
}


class PlayStateManager {

    BehaviourRelay<PlayState> mSubject = new BehaviourRelay();

    public void set(PlayState state) {
       mSubject.accept(state);
    }

    public Observable<PlayState> playState() {
        return mSubject.hide();
    }
}

Answer 1

如果我正确理解您的问题，如果 playState() 是较旧的信息，您不想执行动画，但仅在它切换状态时才执行。换句话说，在onCreate() 的初始调用中，您不想做动画，但如果值发生变化，则想做动画。

enum PlayStateExpanded {
  UNKNOWN,
  PLAYING,
  PAUSED
}

class PlayStateManager {

    BehaviourRelay<PlayStateExpanded> mSubject = 
       new BehaviourRelay(PlayStateExpanded.UNKNOWN);

    public void set(PlayState state) {
       mSubject.accept(
           state == PlayState.PLAYING ? PlayStateExpanded.PLAYING
                                      : PlayStateExpanded.PAUSED);
    }

    public Observable<PlayStateExpanded> playState() {
        return mSubject.hide();
    }
}

void onCreate(SavedinstanceState state) {
  AtomicBoolean firstTime = new AtomicBoolean(true); // note first time
  mPlayStateManager.playState()
    .subscribe(state -> {
       switch(state) {
        case PlayStateExpanded.PLAYING:
            showPlayingState(true, firstTime.get());
            break;
        case PlayStateExpanded.PAUSED:
            showPlayingState(true, firstTime.get());
            break;
       }
       firstTime.set(false); // no longer first time
    }
}

通过使用UNKNOWN 值重新定义播放状态，简化了启动条件。只需为首次使用后重置的第一个过渡添加一个标志即可实现您的既定目标。