RxJava/RxAndroid 检查互联网连接是否可用

我有这个代码来检查互联网连接是否可用。

    public static boolean  isOnline() {
    Runtime runtime = Runtime.getRuntime();
    try {
        Process ipProcess = runtime.exec("/system/bin/ping -c 1 8.8.8.8");
        int exitValue = ipProcess.waitFor();
        return (exitValue == 0);
    } catch (IOException | InterruptedException e) {
        e.printStackTrace();
    }
    return false;
}

现在我想使用 RxJava/RxAndroid 执行相同的任务。那么我该怎么做呢？

如果您被允许使用ConnectivityManager这是检查互联网连接的快速方法：

public static Observable<Boolean> isInternetOn(Context context) {
    ConnectivityManager connectivityManager = (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);
    NetworkInfo activeNetworkInfo = connectivityManager.getActiveNetworkInfo();
    return Observable.just(activeNetworkInfo != null && activeNetworkInfo.isConnected());
    }

然后按如下方式使用它：

private Observable<Object> executeNetworkCall() {
    return isInternetOn(context)
            .filter(connectionStatus -> connectionStatus)
            .switchMap(connectionStatus -> doNetworkCall()));
}

如果您需要更多信息，请参阅此answer https://stackoverflow.com/a/38281335/3990222提供了更详细的说明。