Learning Reactive Programming with Java 8电子书

Learning Reactive Programming with Java 8

Table of Contents

Learning Reactive Programming with Java 8

Credits

About the Author

About the Reviewers

www.PacktPub.com

Support files, eBooks, discount offers, and more

Why subscribe?

Free access for Packt account holders

Preface

What this book covers

What you need for this book

Who this book is for

Conventions

Reader feedback

Customer support

Downloading the example code

Errata

Piracy

Questions

1. An Introduction to Reactive Programming

What is reactive programming?

Why should we be reactive?

Introducing RxJava

Downloading and setting up RxJava

Comparing the iterator pattern and the RxJava Observable

Implementing the reactive sum

Summary

2. Using the Functional Constructions of Java 8

Lambdas in Java 8

Introducing the new syntax and semantics

Functional interfaces in Java 8 and RxJava

Implementing the reactive sum example with lambdas

Pure functions and higher order functions

Pure functions

Higher order functions

RxJava and functional programming

Summary

3. 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 ConnectableObservable class

The Subject instances

Summary

4. Transforming, Filtering, and Accumulating Your Data

Observable transformations

Transformations with the various flatMap operators

Grouping items

Additional useful transformation operators

Filtering data

Accumulating data

Summary

5. Combinators, Conditionals, and Error Handling

Combining the Observable instances

The zip operator

The combineLatest operator

The merge operator

The concat operator

The conditional operators

The amb operator

The takeUntil(), takeWhile(), skipUntil(), and skipWhile() conditional operators

The defaultIfEmpty( ) operator

Handling errors

The return and resume operators

The retrying technique

An HTTP client example

Summary

6. Using Concurrency and Parallelism with Schedulers

RxJava's schedulers

Debugging Observables and their schedulers

The interval Observable and its default scheduler

Types of schedulers

The Schedulers.immediate scheduler

The Schedulers.trampoline scheduler

The Schedulers.newThread scheduler

The Schedulers.computation scheduler

The Schedulers.io scheduler

The Schedulers.from(Executor) method

Combining Observables and schedulers

The Observable<T> subscribeOn(Scheduler) method

The Observable<T> observeOn(Scheduler) operator

Parallelism

Buffering, throttling, and debouncing

Throttling

Debouncing

The buffer and window operators

The backpressure operators

Summary

7. 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

Introducing the Observable.using method

Caching data with Observable.cache

Creating custom operators with lift

Composing multiple operators with the Observable.compose operator

Summary

Index