umair13adil

dependencies {

    //RxJava2
    implementation 'io.reactivex.rxjava2:rxandroid:2.1.0'
    implementation 'io.reactivex.rxjava2:rxjava:2.2.3'
    implementation  'io.reactivex.rxjava2:rxkotlin:2.2.0'
    
    //Glide
    implementation 'com.github.bumptech.glide:glide:4.8.0'
    kapt "androidx.lifecycle:lifecycle-compiler:2.1.0-alpha01"

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.*
import java.util.concurrent.TimeUnit

class ExampleUnitTest {

    @Test
    @Throws(Exception::class)

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() {