ragdroid

// Use concat and repeat to renew the session repeatedly    
 Observable<Session> getRenewedSession() {
       Observable<Session> sessionObservable = 
       SessionManager.getCurrentSessionObservable()
               .filter(new Func1<Session, Boolean>() {
                   @Override
                   public Boolean call(Session session) {
                       return session.isValid();
                   }

ragdroid

 service.startupDetails(request)
   .doOnNext(new Action1<StartupDetails>() {
     @Override
     public void call(StartupDetails startupDetails) {
       startupStore.putStartupDetails(startupDetails);
     }
   })
   .onErrorReturn(new Function<Throwable, StartupDetails>() {
     @Override

ragdroid

//Use concat-Map() to maintain order while performing "Auto-Complete Search"  
publishSubject
  .debounce(300, TimeUnit.MILLISECONDS)
  .concatMap(new Function<String, ObservableSource<List<Book>>>() {
      @Override
      public ObservableSource<List<Book>> apply(String s) throws Exception {
          Log.d(TAG, "getting books for " + s);
          return dataSource.getBook(s);
          }

ragdroid

//Order is not maintain if we use flatMap() while performing "Auto-Complete Search"  
publishSubject
  .debounce(300, TimeUnit.MILLISECONDS)
  .flatMap(new Function<String, ObservableSource<List<Book>>>() {
      @Override
      public ObservableSource<List<Book>> apply(String s) throws Exception {
          Log.d(TAG, "getting books for " + s);
          return dataSource.getBook(s);
          }

ragdroid

  pokeSource.getPokemonAbilityStringObservable("12")
               .subscribeOn(provider.io())
                .observeOn(provider.ui())
                .subscribe(new Consumer<Pokemon>() {
                    @Override
                    public void accept(@NonNull String pokemonAbility) throws Exception {
                        if (getView() != null) {
                            getView().setApiText(pokemonAbility);
                        }

ragdroid

if (throwable instanceof HttpException) {
    if (((HttpException) throwable).code() == 
                                    HttpURLConnection.HTTP_NOT_FOUND) {
         if (getView() != null) {
              getView().showErrorDialog("Lost!");
             }
        } else if (((HttpException) throwable).code() == 
                                    HttpURLConnection.HTTP_UNAVAILABLE) {
          if (getView() != null) {

ragdroid

public class LocalResponseDispatcher extends QueueDispatcher {

    @Override
    public MockResponse dispatch(RecordedRequest request) throws InterruptedException {
        MockResponse mockResponse = new MockResponse();
        String scenario = getScenario(request);
        if (scenario != null) {
            try {
                mockResponse.setBody(readFile(scenario));

ragdroid

    @Test
    public void testOnSceneAdded() {
        reset(mainSceneMock);
        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokemonService);

        presenter.onSceneAdded(mainSceneMock, null);

        testScheduler.triggerActions();

ragdroid

    @Test
    public void testDemoResponseError503() {
        reset(mainSceneMock);
        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokemonService);

        MockResponse response = new MockResponse();
        response.setResponseCode(HttpURLConnection.HTTP_UNAVAILABLE);

        getErrorMockWebServer().enqueue(response);

ragdroid

    @Test
    public void testDemoResponseErrorSocket() {
        reset(mainSceneMock);

        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokemonService);

        MockResponse response = new MockResponse();
        response.setBody("\"message\":\"Hello\"").throttleBody(1, 2, TimeUnit.SECONDS);