Book Image

Learning Reactive Programming with Java 8

By : Nickolay Tzvetinov
Book Image

Learning Reactive Programming with Java 8

By: Nickolay Tzvetinov

Overview of this book

Related Content you might be interested in

Current Title:

Small book image
Learning Reactive Programming with Java 8
Nickolay Tzvetinov
Jun, 2015 | 182 pages
No titles found
Table of Contents (15 chapters)
Learning Reactive Programming with Java 8
Learning Reactive Programming with Java 8
Credits
Credits
About the Author
About the Author
About the Reviewers
About the Reviewers
www.PacktPub.com
www.PacktPub.com
Preface
Preface
Free Chapter
1
An Introduction to Reactive Programming
An Introduction to Reactive Programming
What is reactive programming?
Why should we be reactive?
Introducing RxJava
Summary
2
Using the Functional Constructions of Java 8
Using the Functional Constructions of Java 8
Lambdas in Java 8
Implementing the reactive sum example with lambdas
Pure functions and higher order functions
Summary
3
Creating and Connecting Observables, Observers, and Subjects
Creating and Connecting Observables, Observers, and Subjects
The Observable.from method
The Observable.just method
Other Observable factory methods
The Observable.create method
Subscribing and unsubscribing
Hot and cold Observable instances
The Subject instances
Summary
4
Transforming, Filtering, and Accumulating Your Data
Transforming, Filtering, and Accumulating Your Data
Observable transformations
Filtering data
Accumulating data
Summary
5
Combinators, Conditionals, and Error Handling
Combinators, Conditionals, and Error Handling
Combining the Observable instances
The conditional operators
Handling errors
An HTTP client example
Summary
6
Using Concurrency and Parallelism with Schedulers
Using Concurrency and Parallelism with Schedulers
RxJava's schedulers
Buffering, throttling, and debouncing
Summary
7
Testing Your RxJava Application
Testing Your RxJava Application
Testing using simple subscription
The BlockingObservable class
The aggregate operators and the BlockingObservable class
Testing with the aggregate operators and the BlockingObservable class
Using the TestSubscriber class for in-depth testing
Testing asynchronous Observable instances with the help of the TestScheduler class
Summary
8
Resource Management and Extending RxJava
Resource Management and Extending RxJava
Resource management
Caching data with Observable.cache
Creating custom operators with lift
Composing multiple operators with the Observable.compose operator
Summary
Index
Index

Subscribing and unsubscribing

The Observable.subscribe() method has many overloads as follows:

  • subscribe(): This one ignores all the emissions from the Observable instance and throws an OnErrorNotImplementedException exception if there is an OnError notification. This can be used to only trigger the OnSubscribe.call behavior.

  • subscribe(Action1<? super T>): This only subscribes to onNext() method-triggered updates. It ignores the OnCompleted notification and throws an OnErrorNotImplementedException exception if there is an OnError notification. It is not a good choice for real production code, because it is hard to guarantee that no errors will be thrown.

  • subscribe(Action1<? super T>, Action1<Throwable>): This is the same as preceding one, but the second parameter is called if there is an OnError notification.

  • subscribe(Action1<? super T>,Action1<Throwable>, Action0): This is the same as the preceding one, but the third parameter is called on OnCompleted notification...

Previous Section
End of Section 6
Next Section