umair13adil

var tasksList: RealmList<Tasks>
tasksList = RealmList()

getPendingTasks(3)
              .flatMapIterable { it -> it }
              .concatMap { task ->
                  getPendingSubTasks(task.id)
                  .doOnNext {
                      //Here we are binding subtasks to individual task item
                      bindChildTasks(it, task)

umair13adil

import io.reactivex.Observable
import io.reactivex.schedulers.TestScheduler
import org.junit.Test
import java.util.concurrent.TimeUnit

class MergeUnitTest {

    @Test
    @Throws(Exception::class)
    fun mergeSimple() {

umair13adil

import io.reactivex.Observable
import io.reactivex.schedulers.TestScheduler
import org.junit.Test
import java.util.*
import java.util.concurrent.TimeUnit

class ExampleUnitTest {

    @Test
    @Throws(Exception::class)

umair13adil

import android.os.Bundle;
import android.support.annotation.NonNull;
import android.support.design.widget.TextInputLayout;
import android.support.v4.widget.NestedScrollView;
import android.support.v7.app.AppCompatActivity;
import android.support.v7.widget.AppCompatButton;
import android.support.v7.widget.AppCompatEditText;
import android.text.TextUtils;
import android.util.Log;
import android.view.View;