package com.murki.flckrdr.repository;

import android.content.Context;
import android.content.SharedPreferences;
import android.preference.PreferenceManager;

import com.fernandocejas.frodo.annotation.RxLogObservable;
import com.murki.flckrdr.model.RecentPhotosResponse;
import com.squareup.moshi.JsonAdapter;
import com.squareup.moshi.Moshi;
import com.squareup.moshi.Types;

import java.lang.reflect.Type;

import rx.Observable;
import rx.Subscriber;
import rx.schedulers.Timestamped;

public class FlickrDiskRepository {

    private final static String RECENT_PHOTOS_RESPONSE_KEY = "com.murki.flckrdr.model.RecentPhotosResponse_key";

    private final SharedPreferences sharedPreferences;
    private final JsonAdapter<Timestamped<RecentPhotosResponse>> flickrPhotosJsonAdapter;

    public FlickrDiskRepository(Context context) {
        sharedPreferences = PreferenceManager.getDefaultSharedPreferences(context);
        Moshi moshi = new Moshi.Builder().build();
        Type adapterType = Types.newParameterizedType(Timestamped.class, RecentPhotosResponse.class);
        flickrPhotosJsonAdapter = moshi.adapter(adapterType);
    }

    public void savePhotos(Timestamped<RecentPhotosResponse> photos) {
        String serializedPhotoList = flickrPhotosJsonAdapter.toJson(photos);
        sharedPreferences.edit().putString(RECENT_PHOTOS_RESPONSE_KEY, serializedPhotoList).commit();
    }

    @RxLogObservable
    public Observable<Timestamped<RecentPhotosResponse>> getRecentPhotos() {
        return Observable.create(new Observable.OnSubscribe<Timestamped<RecentPhotosResponse>>() {
            @Override
            public void call(Subscriber<? super Timestamped<RecentPhotosResponse>> subscriber) {
                try {
                    String serializedPhotoList = sharedPreferences.getString(RECENT_PHOTOS_RESPONSE_KEY, "");
                    Timestamped<RecentPhotosResponse> photos = flickrPhotosJsonAdapter.fromJson(serializedPhotoList);
                    subscriber.onNext(photos);
                    subscriber.onCompleted();
                } catch (Exception ex) {
                    subscriber.onError(ex);
                }
            }
        });
    }
}
@@ -1379,14 +1379,13 @@
 st).
-commit
+apply
 ();%0A

Use .apply() for the saving of data since we don't want to wait to emit the observable until the data is saved