Введение

Что такое наблюдаемое?

Observable - это массив, элементы которого поступают с течением времени. Их можно использовать для моделирования потоков асинхронных данных, таких как события DOM, асинхронные запросы и анимации. Их также можно преобразовывать, комбинировать и использовать с помощью методов массива, таких как map, filter, reduce, forEach и т. Д.

Что такое операторы?

Операторы применяют определенные преобразования к наблюдаемой последовательности. Эти преобразования могут относиться к любой категории, например, создание, преобразование, комбинирование, функциональное, математическое, временное, исключительное, разное, выбор и примитивы.

Установка

npm install rxjs --save

Импорт в ваш проект

import { Observable } from 'rxjs/Rx';

Использование наблюдаемых и операторов с примерами

Observable.from

Этот метод создает новую наблюдаемую последовательность из массива значений.

Observable.of

Преобразует аргументы в наблюдаемую последовательность.

Наблюдаемый диапазон

Создает наблюдаемую последовательность чисел в указанном диапазоне.

Observable.fromEvent

Создает наблюдаемую последовательность из события.

Observable.distinctUntilChanged

Создает наблюдаемую последовательность без повторяющихся значений.

Observable.delay

Создает наблюдаемую последовательность с задержкой.

Observable.throttleTime

Создает наблюдаемую последовательность, которая выдает только первое значение в течение заданного периода времени.

Observable.debounceTime

Создает наблюдаемую последовательность, которая выдает только последнее значение по истечении заданного времени.

Исходный код

Пример проекта с использованием операторов fromEvent, independentUntilChanged, delay, throttleTime и debounceTime доступен ниже. Не стесняйтесь попробовать.



joelgeorgev / learning-observable-typescript
learning-observable-typescript - начальный проект с использованием RxJS Observable в TypeScript github.com



GIF вывода приложения показан ниже.

Справочник по API

Http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html