WifiSwap.java 文件源码

@Override
public void start() {
    Utils.debugLog(TAG, "Preparing swap webserver.");
    sendBroadcast(SwapService.EXTRA_STARTING);

    if (FDroidApp.ipAddressString == null) {
        Log.e(TAG, "Not starting swap webserver, because we don't seem to be connected to a network.");
        setConnected(false);
    }

    Single.zip(
            Single.create(getWebServerTask()),
            Single.create(getBonjourTask()),
            new Func2<Boolean, Boolean, Boolean>() {
                @Override
                public Boolean call(Boolean webServerTask, Boolean bonjourServiceTask) {
                    return bonjourServiceTask && webServerTask;
                }
            })
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.newThread())
            .subscribe(new Action1<Boolean>() {
                    @Override
                    public void call(Boolean success) {
                        setConnected(success);
                    }
                },
                new Action1<Throwable>() {
                    @Override
                    public void call(Throwable throwable) {
                        setConnected(false);
                    }
                });
}