gistfile1.txt

    /**
     * toggleAutoDownflow() : method triggered by remote config, should
     * be used when notifications based downflow is broken.
     */
    private fun toggleAutoDownflow() {
        automaticDownflowDisposable?.dispose()
        isAutomaticDownflowActivated = remoteConfig.automaticDownflow.activated
        automaticDownflowIntervalInMinutes = remoteConfig.automaticDownflow.intervalInMinutes

        if (isAutomaticDownflowActivated) {
            automaticDownflowDisposable =
                Observable
                    .interval(automaticDownflowIntervalInMinutes, MINUTES)
                    .doOnNext {
                        if (autoDownflowTourneeAndOtDisposable == null ||
                            autoDownflowTourneeAndOtDisposable?.isDisposed == true
                        ) {
                            downflowTourneeAndOtDisposable = initAutoDownflowTourneeAndOtSubject()
                        }
                        autoDownflowTourneeAndOtSubject
                            .onNext(null)
                    }
                    .subscribe({}, { logger.logException(AutomaticDownflowException(it.message)) })
                    .addTo(compositeDisposable)
        }
    }

    private fun initAutoUpflowObservable() = automaticUpflowObservable
        .subscribe({}, { logger.logException(AutomaticUpflowException(it.message)) })
        .addTo(compositeDisposable)