A Lesson by Donn Felker
In this lesson, you will learn how to create an observable source based upon primitive types and objects through the use of the
Observable.just operator. You will learn how to create the source and subscribe to it so that you can receive the values. You’ll learn about the terminal events,
onError and when they’re called. The lesson wraps up with a demonstration of how the
just operator will terminate upon encountering an error in the stream of items.
This example is demonstrated in RxJava 2 with Consumers and Actions and is written in Kotlin.
Code for the Lesson
Pro members: Log in to view the code for this lesson!
Lessons in this course
- RxJava 2 – compose() Operator
- RxJava 2 – Disposing of Subscriptions with Disposable
- RxJava Operators – Observable.just()
- RxJava: fromCallable vs defer – The differences between the two operators
- RxJava Operators – defer()
- RxJava Marble Diagrams
- RxJava fromCallable – Converting slow methods into an Observable
- RxJava Operators – observeOn
- RxJava Operators – subscribeOn
- Retrofit 2 with RxJava
- Grokking RxJava’s Observable.amb Operator
- Understanding the RxJava Observable.zip Operator
- RxJava Error Handling with Observable.error()
- Introduction to RxJava for Android Developers