Detecting network change with ConnectivityManager & RxJava

class NetworkControl @Inject constructor(context: Context) {

    private val cm = context.getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager
    private val tm = context.getSystemService(Context.TELEPHONY_SERVICE) as TelephonyManager

    private val mobileNetworkOperator: String
        get() = "${tm.networkOperatorName} (${tm.networkOperator})"

    private val networkMonitorSubject = BehaviorSubject.create<State>()

    val stateObservable: Observable<State> =
        networkMonitorSubject
            .hide()
            .startWith(currentState)
            .distinctUntilChanged()
            .debounce(2, TimeUnit.SECONDS)

    val currentState: State
        get() = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) {
            cm.getNetworkCapabilities(cm.activeNetwork)?.run {
                createNetworkState(hasTransport(NetworkCapabilities.TRANSPORT_CELLULAR))
            } ?: createNetworkState()
        } else {
            cm.activeNetworkInfo?.run {
                createNetworkState(type == ConnectivityManager.TYPE_MOBILE)
            } ?: createNetworkState()
        }

    fun refreshNetworkState() {
        networkMonitorSubject.onNext(currentState)
    }

    private val isOnline: Boolean
        get() {
            val activeNetworkInfo = cm.activeNetworkInfo
            return activeNetworkInfo != null && activeNetworkInfo.isConnected
        }

    private fun createNetworkState(isCellular: Boolean = false): State = State(!isOnline, isCellular, mobileNetworkOperator)

    data class State(
        val isOffline: Boolean,
        val isMetered: Boolean,
        val mobileNetworkOperator: String
    ) {
        val isOnline: Boolean
            get() = !isOffline
    }
}