kakai248

private TimedCacheSource<Discover> discoverObservable = TimedCacheSource.createWithTimeout(30, TimeUnit.SECONDS);

public Single<Discover> getProviders() {
    return discoverObservable.switchIfEmpty(fetchProviders().doOnSuccess(discoverObservable));
}

kakai248

public class ResourceProvider {

    private final Context context;

    @Inject
    public ResourceProvider(Context context) {
        this.context = context;
    }

    @NonNull

kakai248

package me.mesmo.app.presentation.views;

import android.content.Context;
import android.content.res.TypedArray;
import android.graphics.Canvas;
import android.graphics.Paint;
import android.support.annotation.ColorInt;
import android.support.annotation.Nullable;
import android.support.v7.widget.AppCompatTextView;
import android.text.Layout;

kakai248

import java.util.concurrent.TimeUnit;

import io.reactivex.ObservableOperator;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class FilterWithTimeout<T> implements ObservableOperator<T, T> {

    private final long intervalDuration;
    private final TimeUnit unit;

kakai248

public class ViewModelInjectionFactory<VM extends ViewModel> implements ViewModelProvider.Factory {

    private Lazy<VM> viewModel;

    @Inject
    public ViewModelInjectionFactory(Lazy<VM> viewModel) {
        this.viewModel = viewModel;
    }

    @Override