@Test public void getExoPlayerStateOnceAndStream_emitsObservableValue() { new ArrangeBuilder() .withExoPlayerState(TEST_INITIAL_EXOPLAYER_STATE); defaultObservableExoPlayer.getExoPlayerStateOnceAndStream() .test() .assertValue(TEST_INITIAL_EXOPLAYER_STATE); }
@NonNull @Override public Observable<ExoPlayerState> getExoPlayerStateOnceAndStream() { return stateOnceAndStream; }
DefaultObservableExoPlayer implements ObservableExoPlayer { @NonNull @Override public Observable<ExoPlayerState> getExoPlayerStateOnceAndStream() { return stateOnceAndStream; } }
DefaultObservableExoPlayer implements ObservableExoPlayer { @NonNull @Override public Observable<ExoPlayerState> getExoPlayerStateOnceAndStream() { return stateOnceAndStream; } @Inject  DefaultObservableExoPlayer(@NonNull final Observable<ExoPlayerState> stateOnceAndStream,
                               @NonNull final Observable<Long> progressOnceAndStream,
                               @NonNull final SchedulerProvider schedulerProvider); }
DefaultObservableExoPlayer implements ObservableExoPlayer { @NonNull @Override public Observable<ExoPlayerState> getExoPlayerStateOnceAndStream() { return stateOnceAndStream; } @Inject  DefaultObservableExoPlayer(@NonNull final Observable<ExoPlayerState> stateOnceAndStream,
                               @NonNull final Observable<Long> progressOnceAndStream,
                               @NonNull final SchedulerProvider schedulerProvider); @NonNull @Override Observable<ExoPlayerState> getExoPlayerStateOnceAndStream(); @NonNull @Override Observable<Long> getTimePositionMsOnceAndStream(long updatePeriod,
                                                           @NonNull final TimeUnit timeUnit); }
DefaultObservableExoPlayer implements ObservableExoPlayer { @NonNull @Override public Observable<ExoPlayerState> getExoPlayerStateOnceAndStream() { return stateOnceAndStream; } @Inject  DefaultObservableExoPlayer(@NonNull final Observable<ExoPlayerState> stateOnceAndStream,
                               @NonNull final Observable<Long> progressOnceAndStream,
                               @NonNull final SchedulerProvider schedulerProvider); @NonNull @Override Observable<ExoPlayerState> getExoPlayerStateOnceAndStream(); @NonNull @Override Observable<Long> getTimePositionMsOnceAndStream(long updatePeriod,
                                                           @NonNull final TimeUnit timeUnit);  }