BasePresenter.kt

/**
		* The method add default method [handleError] for handle onError evert from the ObservableSource,
		* and add disposable from this subscribe to CompositeDisposable [compositeDisposable]
		*
		* @param onNext - the function you have designed to accept emissions from the ObservableSource
		*/
	protected fun <T> Observable<T>.safeSubscribe(onNext: (T) -> Unit, onError: (Throwable) -> Unit = ::handleError) {
		this.subscribe(onNext, onError)
				.addToCompositeDisposable()
	}
	
	/**
		* The method add default method [handleError] for handle onError evert from the SingleSource,
		* and add disposable from this subscribe to CompositeDisposable [compositeDisposable]
		*
		* @param onNext - the function you have designed to accept emissions from the SingleSource
		*/
	protected fun <T> Single<T>.safeSubscribe(onNext: (T) -> Unit, onError: (Throwable) -> Unit = ::handleError) {
		this.subscribe(onNext, onError)
				.addToCompositeDisposable()
	}
	
	protected fun Completable.safeSubscribe(onNext: () -> Unit, onError: (Throwable) -> Unit = ::handleError) {
		this.subscribe(onNext, onError)
				.addToCompositeDisposable()
	}