ohos.permission.INTERNET
ohos.permission.GET_NETWORK_INFO

{
  "deviceConfig": {
    "default": {
      "network": {
        "cleartextTraffic": true
      }
    }
  }
}

ReactiveNetwork
  .observeNetworkConnectivity(context)
  .subscribeOn(Schedulers.io())
  ... // что угодно еще, что можно сделать с RxJava
  .observeOn(HarmonySchedulers.mainThread())
  .subscribe(connectivity -> {
      // делайте что-то с connectivity
      // вы можете вызвать connectivity.getNetworkState();
      // или connectivity.getNetworkCapabilities();
  },
  throwable -> { /* обрабатывайте ошибку здесь */});
```Когда `Connectivity` меняется, подписчики будут уведомлены. `Connectivity` может менять своё состояние или тип.

**Ошибки** могут быть обработаны таким же образом, как и во всех Observable RxJava. Например:

### Наблюдение за состоянием интернет-соединения

#### Наблюдение за состоянием интернет-соединения постоянно

Можно наблюдать за состоянием интернет-соединения постоянно следующим образом:

Объект `Observable` вернёт `true` в подписке (disposing) если устройство подключено к Интернету и `false` если нет.

Проверка подключения к Интернету будет выполнена _по возможности как можно быстрее_.**Примечание:** Этот метод менее эффективен, чем метод `observeNetworkConnectivity(context)`, так как при использовании стандартной стратегии наблюдения он открывает сокетное соединение с удалённым хостом каждые две секунды с тайм-аутом в две секунды и потребляет трафик. Используйте этот метод, если это действительно необходимо. В качестве альтернативы вы можете отменить подписку (disposing) сразу после получения уведомления о доступности Интернета и выполнить необходимую работу, чтобы уменьшить количество сетевых запросов.Методы в этом разделе следует использовать, если они действительно необходимы из-за специфических случаев использования.

Если вы хотите настроить наблюдение за подключением к интернету, вы можете использовать класс `InternetObservingSettings` и его билдер.
Они позволяют настраивать интервал мониторинга в миллисекундах, хост, порт, таймаут, начальный интервал мониторинга, ожидаемый код ответа HTTP, обработчик ошибок или всю стратегию наблюдения.

```java
InternetObservingSettings settings = InternetObservingSettings.builder()
  .initialInterval(initialInterval)
  .interval(interval)
  .host(host)
  .port(port)
  .timeout(timeout)
  .httpResponse(httpResponse)
  .errorHandler(testErrorHandler)
  .strategy(strategy)
  .build();

ReactiveNetwork
  .observeInternetConnectivity(settings)
  .subscribeOn(Schedulers.io())
  .observeOn(HarmonySchedulers.mainThread())
  .subscribe(isConnectedToInternet -> {
      // что-то сделать с значением isConnectedToInternet
  },
  throwable    -> { /* обработать ошибку здесь */});

Как и в предыдущем случае, вы можете настроить эту функцию с помощью класса `InternetObservingSettings` и его билдера.

```java
InternetObservingSettings settings = InternetObservingSettings.builder()
  .initialInterval(initialInterval)
  .interval(interval)
  .host(host)
  .port(port)
  .timeout(timeout)
  .httpResponse(httpResponse)
  .errorHandler(testErrorHandler)
  .strategy(strategy)
  .build();

Single<Boolean> single = ReactiveNetwork.checkInternetConnectivity(settings);

single
  .subscribeOn(Schedulers.io())
  .observeOn(HarmonySchedulers.mainThread())
  .subscribe(isConnectedToInternet -> {
      // сделайте что-то с isConnectedToInternet
  },
  throwable    -> { /* обработайте ошибку здесь */} );

InternetObservingSettings settings = InternetObservingSettings.builder()
  .host("www.yourhost.com")
  .port(port)
  .strategy(new SocketInternetObservingStrategy())
  .build();

ReactiveNetwork
  .observeInternetConnectivity(settings)
  .subscribeOn(Schedulers.io())
  .observeOn(HarmonySchedulers.mainThread())
  .subscribe(isConnectedToHost -> {
      // сделайте что-то с isConnectedToHost
  },
  throwable    -> { /* обработайте ошибку здесь */ } );

В случае, когда нам приходят слишком много событий, связанных с изменениями сети, или мы хотим игнорировать предыдущие наблюдатели (в данном примере только один), после того как они были подписаны, мы можем использовать оператор `switchMapSingle` вместо `flatMapSingle`, чтобы получать обновления только от последнего наблюдателя. В этом случае, это будет наблюдатель, созданный методом `checkInternetConnectivity`.

# Инструкции по установке

Библиотечные зависимости
    ReactiveNetwork зависит от rxohos.har, rxjava3 и gson.

1. Для использования модуля ReactiveNetwork в вашем образце приложения, добавьте нижеуказанную библиотечную зависимость для генерации hap/library.har.

	Измените entry build.gradle следующим образом:
	```
	dependencies {
	    implementation 'io.openharmony.tpc.thirdlib:Rxohos:1.0.0'
        implementation 'io.reactivex.rxjava3:rxjava:3.0.4'
        implementation 'com.google.code.gson:gson:2.8.6'
        implementation project(path: ':library')
	}
	```

2. Для использования ReactiveNetwork в отдельном приложении, добавьте нижеуказанные зависимости и "library.har" в папку libs модуля "entry".
	Измените `entry` `build.gradle` следующим образом:
	```markdown
	dependencies {
		implementation fileTree(dir: 'libs', include: ['*.har'])
		implementation 'io.openharmony.tpc.thirdlib:Rxohos:1.0.0'
		implementation 'io.reactivex.rxjava3:rxjava:3.0.4'
		implementation 'com.google.code.gson:gson:2.8.6'
	}
	```
	Для использования `ReactiveNetwork` из удалённого репозитория в отдельном приложении, добавьте следующие зависимости в `entry` `build.gradle`.	Измените entry build.gradle следующим образом:
	```
	dependencies {
		implementation 'io.openharmony.tpc.thirdlib:Rxohos:1.0.0'
		implementation 'io.openharmony.tpc.thirdlib:ReactiveNetwork:1.0.2'
		implementation 'io.reactivex.rxjava3:rxjava:3.0.4'
		implementation 'com.google.code.gson:gson:2.8.6'
	}

Copyright 2016 Петра Витчена

Разрешено к использованию под лицензией Apache License, Версия 2.0 («Лицензия»); 
вы можете использовать этот файл только в соответствии с Лицензией. 
Вы можете получить копию Лицензии по адресу

   http://www.apache.org/licenses/LICENSE-2.0

Если применимое законодательство или письменное соглашение не требуют этого, программное обеспечение,
распространяемое под Лицензией, распространяется «КАК ЕСТЬ», БЕЗ КАКИХ-ЛИБО ГАРАНТИЙ, явных или подразумеваемых. 
Смотрите Лицензию для конкретного языка, регламентирующего права и условия использования.