В моей предыдущей статье о создании Reactive API с использованием Vert.x и RxJava мы увидели, как обрабатывать HTTP-запросы асинхронно, используя рабочую очередь, и фиктивный Async API, который асинхронно возвращает результаты. Вы можете увидеть асинхронный способ обработки каждого запроса. Становится все более важным понимать, как API ведет себя под нагрузкой и на что тратится время. Способ визуализации внутренней работы API в реальном времени поможет понять, как приложение..

Авторы: Иван Моргилло, Саша Секулич и Фабрицио Чиньоли Эта статья взята из Grokking ReactiveX . После жизни, посвященной императивному программированию, переход к реактивному мышлению может показаться сложной задачей: «Почему я должен отказаться от всякого контроля и склониться к тому, что« контролируют данные »?» Давайте посмотрим на это в повседневной жизни: на систему кондиционирования воздуха. Сегодня жаркий день, и мы хотим запустить систему кондиционирования, когда..

RxJava - Flowables - Что, когда и как использовать? Чтобы понять Flowables, нам сначала нужно понять Observables. Наблюдаемые - это те объекты, которые мы наблюдаем за любым событием. Наблюдаемые используются, когда у нас относительно мало элементов за время и нет риска переполнения потребителей. Если есть вероятность того, что потребитель может быть переполнен, мы используем Flowable. Одним из примеров может быть получение огромного количества данных с датчика. Обычно они..

В предыдущей части этой статьи мы упоминали некоторые концепции, такие как декларативный стиль , побочные эффекты или функциональные принципы . А теперь пора поговорить о стиле Reactive и о том, как мы можем совместить функциональное и реактивное программирование. Как стать реактивным? Представим, что мы работаем над следующей пользовательской историей: As a Customer, I want to filter a set of videos by a Genre ... Кроме того, мы уже используем репозиторий ,..