PolymorphicObservableFlowableTest.kt

PolymorphicObservableFlowableTest.kt

object test {

  @JvmStatic
  fun main(args: Array<String>): Unit {
    val user1 = User(UserId("user1"))
    val user2 = User(UserId("user2"))
    val user3 = User(UserId("unknown user"))

    val observableModule = Module(ObservableK.async())
    observableModule.run {
      repository.allTasksByUser(user1).fix().observable.subscribe { println(it) }
      repository.allTasksByUser(user2).fix().observable.subscribe { println(it) }
      repository.allTasksByUser(user3).fix().observable.subscribe({ println(it) }, { println(it) })
    }

    val flowableModule = Module(FlowableK.async())
    flowableModule.run {
      repository.allTasksByUser(user1).fix().flowable.subscribe { println(it) }
      repository.allTasksByUser(user2).fix().flowable.subscribe { println(it) }
      repository.allTasksByUser(user3).fix().flowable.subscribe({ println(it) }, { println(it) })
    }
  }
}