chibatching

import android.arch.paging.AsyncPagedListDiffer;
import android.arch.paging.PagedList;
import android.support.annotation.NonNull;
import android.support.v7.recyclerview.extensions.AsyncDifferConfig;
import android.support.v7.util.DiffUtil;
import android.support.v7.util.ListUpdateCallback;

import com.xwray.groupie.Group;
import com.xwray.groupie.GroupDataObserver;
import com.xwray.groupie.Item;

chibatching

class SampleViewModel : ViewModel() {
    val sampleData = UiAsyncLoadLiveData<String> {
        value = try {
            async(coroutineContext + CommonPool) {
                "very long time process!"
            }.await()
        } catch (e: CancellationException) {
            null
        }
    }

chibatching

fun <T> LiveData<T>.asFlow() = flowViaChannel<T?> {
    it.send(value)
    val observer = Observer<T> { t -> it.offer(t) }
    observeForever(observer)
    it.invokeOnClose {
        removeObserver(observer)
    }
}

val text = MutableLiveData<String>()

chibatching

fun <T> Flow<T>.throttle(waitMillis: Int) = flow {
    coroutineScope {
        val context = coroutineContext
        var nextMillis = 0L
        var delayPost: Deferred<Unit>? = null
        collect {
            val current = SystemClock.uptimeMillis()
            if (nextMillis < current) {
                nextMillis = current + waitMillis

chibatching

import androidx.fragment.app.viewModels
import dagger.android.support.DaggerFragment

class SomeFragment : DaggerFragment() {

    @Inject
    lateinit var viewModelFactory: ViewModelFactory<SomeViewModel>

    private val viewModel: SomeViewModel by viewModels { viewModelFactory }

chibatching

SomePref::class.declaredMemberProperties
    .forEach { property ->
        property.isAccessible = true
        (property.getDelegate(SomePref) as? AbstractPref<Any>)?.let {
            it.setToPreference(property, property.get(SomePref)!!, SomePref.preferences)
            println("save preference ${property.name} -> ${property.get(SomePref)}")
        }
        (property.getDelegate(SomePref) as? AbstractStringSetPref)?.let {
            getSharedPreferences(SomePref.kotprefName, Context.MODE_PRIVATE)
                .edit()