josinSbazin/NetworkFlow

NetworkFlow

NetworkFlow is a network state based on coroutine's flow. It's designed to listen network state changes. There are different strategies of listening: using socket with connecting to some host and android API which is based on network adapter state.

Observing network state

  val networkFlowChecker = NetworkFlow(appContext) // can be injected with any DI framework 
  viewModelScope.launch {
    networkFlowChecker.observeNetworkState(appContext)
        .collect {
            Log.d("DEBUG", "value = $it")
  }

It returns Connectivity to collector that stores set of connection type and roaming information.

Observing internet connection through connect to host strategy

  val networkFlowChecker = NetworkFlow(appContext) // can be injected with any DI framework 
  viewModelScope.launch {
        networkFlowChecker.observeInternetConnectivity().flowOn(Dispatchers.IO).collect {
            Log.d("DEBUG", "is connected = $it")
        }
  }

It returns boolean to collector which indicates if connected or not connected to the internet.

Usage

Add specific maven repository to repositories closure. For example, you should add it to root of build.gradle:

allprojects {
  repositories {
    maven { url "https://dl.bintray.com/lion4ik/maven" }
  }
}

Add dependency:

dependencies {
   implementation "com.github.lion4ik:NetworkFlow:$version"
}

where recommended $version is the latest from Download badge

Note

This solution was inspired by https://github.com/pwittchen/ReactiveNetwork which is based on RxJava. The idea is to implement the same stuff based on coroutines.