aanandshekharroy

Observable.fromArray(1,2,3,4)
  .subscribeBy(
        onNext = {
            if(it==2){
                  throw (RuntimeException("Exception on 2"))
            }
            println(it)
        },
        onComplete = {
            println("Completed")

aanandshekharroy

Observable.fromArray(1,2,3,4)
  .subscribeBy(
      onNext = {
          println(it)
      },
      onComplete = {
          println("Completed")
      },
      onError = {
          println(it.message)

aanandshekharroy

import junitparams.JUnitParamsRunner
import junitparams.Parameters
import org.junit.Test;

import  org.junit.Assert.*;
import org.junit.Before
import org.junit.runner.RunWith
import org.junit.runners.Parameterized
import java.util.*