ReactiveNetwork is an Android library listening network connection state and change of the WiFi signal strength with RxJava Observables. It's a successor of Network Events library rewritten with Reactive Programming approach.
Library is compatible with RxJava 1.0.+ and RxAndroid 1.0.+ and uses them under the hood.
min sdk version = 9
JavaDoc is available at: http://pwittchen.github.io/ReactiveNetwork/
Library has two RxJava Observables available in the public API:
Observable<ConnectivityStatus> observeConnectivity(final Context context)
Observable<List<ScanResult>> observeWifiAccessPoints(final Context context)ConnectivityStatus can have one of the following values:
public enum ConnectivityStatus {
UNDEFINED("undefined"),
WIFI_CONNECTED("connected to WiFi"),
MOBILE_CONNECTED("connected to mobile network"),
OFFLINE("offline");
...
} We can observe ConnectivityStatus with observeConnectivity(context) method in the following way:
new ReactiveNetwork().observeConnectivity(context)
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())
... // anything else what you can do with RxJava
.subscribe(new Action1<ConnectivityStatus>() {
@Override public void call(ConnectivityStatus connectivityStatus) {
// do something with connectivityStatus
}
});When ConnectivityStatus changes, subscriber will be notified.
We can react on a concrete status or statuses with the filter(...) method from RxJava, isEqualTo(final ConnectivityStatus... statuses) and isNotEqualTo(final ConnectivityStatus... statuses) methods located in ConnectivityStatus.
new ReactiveNetwork().observeConnectivity(context)
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())
.filter(ConnectivityStatus.isEqualTo(ConnectivityStatus.WIFI_CONNECTED))
.subscribe(new Action1<ConnectivityStatus>() {
@Override public void call(ConnectivityStatus connectivityStatus) {
// do something with connectivityStatus, which will be WIFI_CONNECTED
}
});We can observe WiFi Access Points with observeWifiAccessPoints(context) method. Subscriber will be called everytime, when strength of the WiFi Access Points signal changes (it usually happens when user is moving around with a mobile device). We can do it in the following way:
new ReactiveNetwork().observeWifiAccessPoints(context)
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())
... // anything else what you can do with RxJava
.subscribe(new Action1<List<ScanResult>>() {
@Override public void call(List<ScanResult> scanResults) {
// do something with scanResults
}
});Exemplary application is located in app directory of this repository.
You can depend on the library through Maven:
<dependency>
<groupId>com.github.pwittchen</groupId>
<artifactId>reactivenetwork</artifactId>
<version>0.0.4</version>
</dependency>or through Gradle:
dependencies {
compile 'com.github.pwittchen:reactivenetwork:0.0.4'
}Tests are available in library/src/androidTest/java/ directory and can be executed on emulator or Android device from Android Studio or CLI with the following command:
./gradlew connectedCheck
Code style used in the project is called SquareAndroid from Java Code Styles repository by Square available at: https://github.com/square/java-code-styles. Currently, library doesn't have checkstyle verification attached. It can be done in the future.
Copyright 2015 Piotr Wittchen
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.