danielgomezrico

import rx.Observable
import rx.Observable.Transformer
import rx.Subscription
import rx.android.schedulers.AndroidSchedulers.mainThread
import rx.schedulers.Schedulers.io

/**
 * Shorthand to set [subscribeOn] and [observeOn] thread for observables
 */
fun <T> Observable<T>.composeForIoTasks(): Observable<T> = compose<T>(Transformer {

atetc

package ***.***.android.utils;

import android.Manifest;
import android.app.Activity;
import android.app.Fragment;
import android.content.Context;
import android.content.pm.PackageManager;
import android.support.v13.app.FragmentCompat;
import android.support.v4.app.ActivityCompat;
import android.support.v4.content.ContextCompat;