RxJavaTag ArchiveSubscribe

RxJava Maybe 1. Introduction In this tutorial, we’ll be looking at the Maybe<T> type in RxJava – which represents a stream which can emit a single value, complete in an empty state or report an error. 2. The Maybe Type Maybe is a special kind of Observable which can only… Continue Reading rxjava-maybe

Schedulers in RxJava 1. Overview In this article, we’re going to focus on different types of Schedulers that we’re going to use in writing multithreading programs based on RxJava Observable’s subscribeOn and observeOn methods. Schedulers give the opportunity to specify where and likely when to execute tasks related to the… Continue Reading rxjava-schedulers

Example of Vertx and RxJava Integration 1. Overview RxJava is a popular library for creating asynchronous and event-based programs, it takes inspiration from the main ideas brought forward by the Reactive Extensions initiative. Vert.x, a project under Eclipse‘s umbrella, offers several components designed from the ground up to fully leverage… Continue Reading vertx-rx-java

RxJava and Error Handling 1. Introduction In this article, we’ll take a look at how to handle exceptions and errors using RxJava. First, keep in mind that the Observable typically does not throw exceptions. Instead, by default, Observable invokes its Observer’s onError() method, notifying the observer that an unrecoverable error… Continue Reading rxjava-error-handling

RxJava One Observable, Multiple Subscribers 1. Overview The default behavior of multiple subscribers isn’t always desirable. In this article, we’ll cover how to change this behavior and handle multiple subscribers in a proper way. But first, let’s have a look at the default behavior of multiple subscribers. 2. Default Behaviour… Continue Reading rxjava-multiple-subscribers-observable

Introduction to RxRelay for RxJava 1. Introduction The popularity of RxJava has led to the creation of multiple third-party libraries that extend its functionality. Many of those libraries were an answer to typical problems that developers were dealing with when using RxJava. RxRelay is one of these solutions. 2. Dealing… Continue Reading rx-relay

How to Test RxJava? 1. Overview In this article, we’ll be looking at ways of testing code written using RxJava. The typical flow we are creating with RxJava consists of an Observable and an Observer. The observable is a source of a data that is a sequence of elements. One… Continue Reading rxjava-testing

Integrating Retrofit with RxJava 1. Overview This article focuses on how to implement a simple RxJava-ready REST Client using Retrofit. We’ll build an example application interacting with the GitHub API – using the standard Retrofit approach, and then we’ll enhance it using RxJava to leverage the advantages of Reactive Programming.… Continue Reading retrofit-rxjava

Combining RxJava Completables 1. Overview In this tutorial, we’ll play with RxJava’s Completable type, which represents a computation result without an actual value. 2. RxJava Dependency Let’s include the RxJava 2 dependency into our Maven project: <dependency> <groupId>io.reactivex.rxjava2</groupId> <artifactId>rxjava</artifactId> <version>2.2.2</version> </dependency> We can usually find the latest version on Maven Central. 3.… Continue Reading rxjava-completable