RxJavaLeakActivity.java

package pl.pszklarska.leakexample;

public class RxJavaLeakActivity extends AppCompatActivity {

    private Subscription pokemonSubscription;

    @Override
    protected void onCreate(@Nullable final Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        pokemonSubscription = PokemonApi.getAllPokemons()
                .repeatWhen(observable -> observable.delay(30, TimeUnit.MINUTES))
                .subscribe(this::doSomething);
    }
}