RxLifecycle helper

BaseActivityRx.kt

protected fun <T> subscribe(observable: Observable<T>?, observer: Observer<T>?, bind: Boolean = true) {
        if (observable != null && observer != null) {
            if (bind) {
                observable
                        .subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread(), true)
                        .bindToLifecycle(this)
                        .subscribe(observer)
            } else {
                observable
                        .subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread(), true)
                        .subscribe(observer)
            }
        }
    }