marcin-adamczewski

favoritesCache = new Cache<Integer, BehaviorSubject<Boolean>>(new Cache.CacheProvider<>() {
    @Override
    public BehaviorSubject<Boolean> load(@Nonnull final Integer postId) {
        return BehaviorSubject.create(false);
    }
});

marcin-adamczewski

public Observable<ResponseOrError<String>> addOrRemoveFromFavs(final int postId) {
    return getIsFavoriteObservable(postId)
        .take(1) // take first value from cache
        .doOnNext(isCurrentlyFavorite -> {
            updateFavorite(postId, !isCurrentlyFavorite); // toggle value before request for better User Experience
        })
        .switchMap(isCurrentlyFavorite -> favsApi.addOrRemoveFromFavs(isCurrentlyFavorite)
            .compose(ResponseOrError.toResponseOrErrorObservable()) // it's changing error event to onNext event to not finish a chain
            .doOnNext(responseOrError -> {
                if (responseOrError.isError()) {

marcin-adamczewski

favsApi.fetchFavoritesRequest()
        .doOnNext(this::updateFavoritesCache);

marcin-adamczewski

void updateFavorite(final @NonNull Integer id, final boolean favorite) {
        favoritesCache.get(id).onNext(favorite);
}

marcin-adamczewski

import org.junit.Test
import kotlin.test.assertEquals
import kotlin.test.assertTrue

object FileNameUtils {

    private const val forbiddenFileNameCharsRegexp = "([\\\\<>:?\"*|/])"

    fun removeForbiddenCharactersFromFileName(fileName: String): String {
        return fileName.replace(forbiddenFileNameCharsRegexp.toRegex(), "")