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

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

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

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

kakai248

package me.mesmo.app.utils.cache;

import com.jakewharton.rxrelay2.PublishRelay;
import com.jakewharton.rxrelay2.Relay;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;

import io.reactivex.Completable;
import io.reactivex.Observable;

kakai248

public interface Consumer<T> {
    void accept(T value);
}

kakai248

import android.annotation.SuppressLint
import android.app.Activity
import android.content.Context
import android.content.res.ColorStateList
import android.content.res.Resources
import android.graphics.Typeface
import android.graphics.drawable.Drawable
import android.view.View
import android.view.animation.Animation
import android.view.animation.AnimationUtils

kakai248

const puppeteerLottie = require("puppeteer-lottie");
const fs = require("fs");

const baseInputDir = "lotties/";
const baseOutputDir = "lotties-rendered/";

const outputExtension = '.mp4';

(async () => {
  await run();

kakai248

@Module
abstract class FragmentBindingModule {

    @Binds
    abstract fun bindFragmentFactory(factory: FragmentInjectionFactory): FragmentFactory

    @Binds
    @IntoMap
    @FragmentKey(MainFragment::class)
    abstract fun bindMainFragment(fragment: MainFragment): Fragment

kakai248

public class ResourceProvider {

    private final Context context;

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

    @NonNull

kakai248

abstract class BaseFragment<VB : ViewBinding>(
    private val bindingFactory: (LayoutInflater, ViewGroup?, Boolean) -> VB
) : Fragment() {

    private var _binding: VB? = null
    val binding: VB
        get() = _binding!!

    override fun onCreateView(
        inflater: LayoutInflater,