Vignesh150493

interface SchedulerProvider {

    fun computation(): Scheduler

    fun io(): Scheduler

    fun ui(): Scheduler

    fun single(): Scheduler

Vignesh150493

class MainController {

  fun getItems() : List<Item> {
    val apiResponse = getItemsFromApi()
    val dbResponse = getItemsFromDb()
    
    return Observable.concatArray(getItemsFromDb().toObservable(), getItemsFromApi().toObservable())
                .onErrorReturn {
                    listOf()
                }

Vignesh150493

import java.time.LocalDateTime

class Boy {
    infix fun name(name : String) {
        println("His name is $name")
    }
}

fun main(args : Array<String>) {
    val boy = Boy()

Vignesh150493

import com.github.pwittchen.reactivenetwork.library.rx2.Connectivity
import io.reactivex.Completable
import io.reactivex.Flowable
import io.reactivex.FlowableTransformer
import io.reactivex.Observable
import com.rv.user.networkerrorretrier.Result

interface NetworkManager {
    /**
     * Exception used to denote that an operation was performed when network was not available.

Vignesh150493

eventBus.observeEventOnUi<EventTypeOne>()
                .map { //Do any transformation if you want to! Bonus! }
                .subscribe { 
                  // Subscriber
                }
                  
eventBus.observeEventOnUi<EventTypeTwo>()
                .subscribe { 
                  // Subscriber
                }

Vignesh150493

/**
 * [EventBus] implementation backed by a [PublishProcessor]
 */
class RxBus : EventBus {
    private val publishProcessor = PublishProcessor.create<Any>()

    override fun postEvent(event: Any) {
        publishProcessor.onNext(event)
    }

Vignesh150493

/**
 * Events are posted to common bus and all active subscribers are notified of changes. Threading and
 * backpresssure can be handled by subscribers.
 */
interface EventBus {
    /**
     * Post an event to bus.
     */
    fun postEvent(event: Any)