RxRelayAwesome

rxRelayAwesome0.java

    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