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` может изменять своё состояние или тип.

**Ошибки** могут быть обработаны таким же образом, как и в любом другом RxJava observable. Например:

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

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

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

`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 -> { /* обрабатывайте ошибку здесь */} );

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

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

Библиотека зависит от 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 следующим образом:
	```
	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'
	}
	```
	3. Для использования 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 Piotr Wittchen

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

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

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