Marchuck

import android.bluetooth.BluetoothGatt;
import android.bluetooth.BluetoothGattCharacteristic;
import android.bluetooth.BluetoothGattDescriptor;
import android.support.annotation.NonNull;
import android.util.Log;
import java.util.UUID;
/**
* Helper which enables or disables BLE gatt updates from connected peripheral, not tested in production
*/

Marchuck

package xD;

import android.content.Context;
import android.content.res.AssetFileDescriptor;
import android.media.MediaPlayer;
import android.util.Log;

import hugo.weaving.DebugLog;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;

Marchuck

CatPresenter{
  
  BehaviorSubject<List<Cat>> catsSubject = BehaviorSubject.create();
  Disposable catsDisposable;
  
 void onCreate(){
   
   someClient.subscribe( cats -> {  catsSubject.onNext(cats)  })

Marchuck

package evalu.com.evalu.utils.rx;

import android.content.Context;
import android.os.Build;
import android.support.annotation.RequiresApi;
import android.util.AttributeSet;
import android.view.MotionEvent;
import android.widget.ScrollView;

import io.reactivex.subjects.PublishSubject;

Marchuck

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical">

    <TextView
        style="@style/textview_bold"
        android:layout_marginBottom="@dimen/activity_small_padding"
        android:layout_marginLeft="@dimen/activity_default_padding"
        android:layout_marginRight="@dimen/activity_default_padding"

Marchuck

interface StarWarsApi {

    @GET("people/")
    fun getPeople(@Query("page") page: Int): Deferred<PeopleResponse>
}

Marchuck

class GetPeopleUseCase(private val api: StarWarsApi) {

    fun execute(page: Int): Deferred<List<Person?>?> {
        return async { transform(page) }
    }

    private suspend fun transform(page: Int): List<Person?> {
        val response = api.getPeople(page).await()

        return response.results ?: emptyList()

Marchuck

class SwapiPeopleDataSource(val useCase: GetPeopleUseCase) : PageKeyedDataSource<Int, Person?>() {

    override fun loadInitial(params: LoadInitialParams<Int>, callback: LoadInitialCallback<Int, Person?>) {
        async {
            val items = useCase.execute(page = 1).await()
            callback.onResult(items.orEmpty(), null, 2)
        }
    }

    override fun loadAfter(params: LoadParams<Int>, callback: LoadCallback<Int, Person?>) {

Marchuck

interface PagedListProvider<Value> {

    fun provide() : LiveData<PagedList<Value>>
}

Marchuck

class SwapiPeoplePagedListProvider(private val factory: DataSource.Factory<Int, Person?>) : PagedListProvider<Person?> {

    override fun provide(): LiveData<PagedList<Person?>> {

        return LivePagedListBuilder(factory, PagedList.Config.Builder()
                .setEnablePlaceholders(false)
                .setPageSize(20)
                .setInitialLoadSizeHint(20)
                .build()
        ).setFetchExecutor(createFetchExecutor())