BaseInternetObservingStrategy.java 文件源码

/** Base observing implementation for all internet observing stategies. */
@Override
@RestrictTo(LIBRARY_GROUP)
public Observable<Boolean> observe() {
  return Observable.interval(delay, interval, TimeUnit.MILLISECONDS).map(toConnectionState())
      .distinctUntilChanged();
}