feresr

public class JokesPresenter extends BasePresenter<JokesView> {

    private JokesStore store;
    private Subscription subscription;

    @Inject
    public JokesPresenter(JokesStore jokesStore) { this.store = jokesStore; }
    
    @Override
    public void onCreate() {

feresr

public class JokesStore extends RxStore<JokeRequest, JokeResponse> {
    
    private JokesEndpoint endpoints;
    
    @Inject
    public JokesStore(JokesEndpoint endpoints) {
        this.endpoints = endpoints;
    }

    @Override

feresr

public abstract class RxStore<Input, Output> {
    private BehaviorSubject<Input> subject = BehaviorSubject.create();
    private Observable<Output> observable;

    public final Subscription register(Subscriber<Output> subscriber) {
        if (observable == null) {
            observable = subject.compose(getTransformer());
        }

        return observable.subscribe(subscriber);

feresr

public abstract class RxStore<Input, Output> {
    private BehaviorRelay<Output> relay = BehaviorRelay.create(defaultValue());

    public final Subscription register(Subscriber<Output> subscriber) {
        return relay.subscribe(subscriber);
    }

    public final void execute(Input event) {
        buildObservable(event).subscribe(relay);
    }

feresr

    public Constructor() {
        observable = endpoints.getJoke().doOnNext(joke -> storage.save(joke)).publish();
    }

    public void execute() {
        observable.connect();
    }

    public Subscription subscribe(Subscriber<Joke> subscriber) { } //subscribe
    public final void unsubscribe(Subscription) { } //unsubscribe

feresr

public class JokesStore extends RxStore<JokeRequest, JokeResponse> {

    private Observable<JokeResponse> buildObservable(JokeRequest event) {
        return endpoints.getJoke(event.jokeNumber)
          .subscribeOn().onBackPressureDrop()
          .doOnNext(joke -> storage.save(joke))
          .onErrorReturn() //create a joke response, set isSuccessful to false)
          .observeOn();
    }

feresr

    public void execute() {
        //doesn't actually execute anything just yet... just creates the observable
        observable = endpoints.getJoke().doOnNext(joke -> storage.save(joke));
    }

    public Subscription subscribe(Subscriber<Joke> subscriber) {
        return observable.subscribe(subscriber);
    }

    public final void unsubscribe(Subscription subscription) { } //unsubscribe

feresr

package com.example.gonzalo_mov.congreso;

import android.os.Bundle;
import android.support.annotation.NonNull;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

feresr

RxView.clicks(button)
        .flatMap(new Func1<Void, Observable<Data>>() {
            @Override
            public Observable<Data> call(Void aVoid) {
                return apiEndpoints
                        .getData()
                        .subscribeOn(Schedulers.io());
            }
        })
        .observeOn(AndroidSchedulers.mainThread())

feresr

content: mock-maker-inline