Reactive Programming with Rxjava
Creating Asynchronous, Event-Based Applications
Published on 6. October 2016
372 pages
978-1-4919-3162-2 (ISBN)
Description
In todays app-driven era, when programs are asynchronous and responsiveness is so vital, reactive programming can help you write code thats more reliable, easier to scale, and better-performing. With this practical book, Java developers will first learn how to view problems in the reactive way, and then build programs that leverage the best features of this exciting new programming paradigm.Authors Tomasz Nurkiewicz and Ben Christensen include concrete examples that use the RxJava library to solve real-world performance issues on Android devices as well as the server. Youll learn how RxJava leverages parallelism and concurrency to help you solve todays problems. This book also provides a preview of the upcoming 2.0 release.Write programs that react to multiple asynchronous sources of input without descending into "e;callback hell"e;Get to that aha! moment when you understand how to solve problems in the reactive wayCope with Observables that produce data too quickly to be consumedExplore strategies to debug and to test programs written in the reactive styleEfficiently exploit parallelism and concurrency in your programsLearn about the transition to RxJava version 2
More details
Language
English
Place of publication
Sebastopol
United States
File size
8,11 MB
ISBN-13
978-1-4919-3162-2 (9781491931622)
Copyright in bibliographic data and cover images is held by Nielsen Book Services Limited or by the publishers or by their respective licensors: all rights reserved.
Schweitzer Classification
Other editions
Additional editions
Tomasz Nurkiewicz | Ben Christiansen | Erik Meijer
Reactive Programming with RxJava
Book
11/2016
O'Reilly
€45.00
Article not available at the moment
Content
- Intro
- Copyright
- Table of Contents
- Foreword
- Introduction
- Who Should Read This Book
- Note from Ben Christensen
- Note from Tomasz Nurkiewicz
- Navigating This Book
- Online Resources
- Conventions Used in This Book
- Safari® Books Online
- How to Contact Us
- Acknowledgments
- From Ben
- From Tomasz
- Chapter 1. Reactive Programming with RxJava
- Reactive Programming and RxJava
- When You Need Reactive Programming
- How RxJava Works
- Push versus Pull
- Async versus Sync
- Concurrency and Parallelism
- Lazy versus Eager
- Duality
- Cardinality
- Mechanical Sympathy: Blocking versus Nonblocking I/O
- Reactive Abstraction
- Chapter 2. Reactive Extensions
- Anatomy of rx.Observable
- Subscribing to Notifications from Observable
- Capturing All Notifications by Using Observer&T&
- Controlling Listeners by Using Subscription and Subscriber&T&
- Creating Observables
- Mastering Observable.create()
- Infinite Streams
- Timing: timer() and interval()
- Hot and Cold Observables
- Use Case: From Callback API to Observable Stream
- Manually Managing Subscribers
- rx.subjects.Subject
- ConnectableObservable
- Single Subscription with publish().refCount()
- ConnectableObservable Lifecycle
- Summary
- Chapter 3. Operators and Transformations
- Core Operators: Mapping and Filtering
- 1-to-1 Transformations Using map()
- Wrapping Up Using flatMap()
- Postponing Events Using the delay() Operator
- Order of Events After flatMap()
- Preserving Order Using concatMap()
- More Than One Observable
- Treating Several Observables as One Using merge()
- Pairwise Composing Using zip() and zipWith()
- When Streams Are Not Synchronized with One Another: combineLatest(), withLatestFrom(), and amb()
- Advanced Operators: collect(), reduce(), scan(), distinct(), and groupBy()
- Scanning Through the Sequence with Scan and Reduce
- Reduction with Mutable Accumulator: collect()
- Asserting Observable Has Exactly One Item Using single()
- Dropping Duplicates Using distinct() and distinctUntilChanged()
- Slicing and Dicing Using skip(), takeWhile(), and Others
- Ways of Combining Streams: concat(), merge(), and switchOnNext()
- Criteria-Based Splitting of Stream Using groupBy()
- Where to Go from Here?
- Writing Customer Operators
- Reusing Operators Using compose()
- Implementing Advanced Operators Using lift()
- Summary
- Chapter 4. Applying Reactive Programming to Existing Applications
- From Collections to Observables
- BlockingObservable: Exiting the Reactive World
- Embracing Laziness
- Composing Observables
- Lazy paging and concatenation
- Imperative Concurrency
- flatMap() as Asynchronous Chaining Operator
- Replacing Callbacks with Streams
- Polling Periodically for Changes
- Multithreading in RxJava
- What Is a Scheduler?
- Declarative Subscription with subscribeOn()
- subscribeOn() Concurrency and Behavior
- Batching Requests Using groupBy()
- Declarative Concurrency with observeOn()
- Other Uses for Schedulers
- Summary
- Chapter 5. Reactive from Top to Bottom
- Beating the C10k Problem
- Traditional Thread-Based HTTP Servers
- Nonblocking HTTP Server with Netty and RxNetty
- Benchmarking Blocking versus Reactive Server
- Reactive HTTP Servers Tour
- HTTP Client Code
- Nonblocking HTTP Client with RxNetty
- Relational Database Access
- NOTIFY AND LISTEN on PostgreSQL Case Study
- CompletableFuture and Streams
- A Short Introduction to CompletableFuture
- Interoperability with CompletableFuture
- Observable versus Single
- Creating and Consuming Single
- Combining Responses Using zip, merge, and concat
- Interoperability with Observable and CompletableFuture
- When to Use Single?
- Summary
- Chapter 6. Flow Control and Backpressure
- Flow Control
- Taking Periodic Samples and Throttling
- Buffering Events to a List
- Moving window
- Skipping Stale Events by Using debounce()
- Backpressure
- Backpressure in RxJava
- Built-in Backpressure
- Producers and Missing Backpressure
- Honoring the Requested Amount of Data
- Summary
- Chapter 7. Testing and Troubleshooting
- Error Handling
- Where Are My Exceptions?
- Declarative try-catch Replacement
- Timing Out When Events Do Not Occur
- Retrying After Failures
- Testing and Debugging
- Virtual Time
- Schedulers in Unit Testing
- Unit Testing
- Monitoring and Debugging
- doOn.() Callbacks
- Measuring and Monitoring
- Summary
- Chapter 8. Case Studies
- Android Development with RxJava
- Avoiding Memory Leaks in Activities
- Retrofit with Native RxJava Support
- Schedulers in Android
- UI Events as Streams
- Managing Failures with Hystrix
- The First Steps with Hystrix
- Nonblocking Commands with HystrixObservableCommand
- Bulkhead Pattern and Fail-Fast
- Batching and Collapsing Commands
- Monitoring and Dashboards
- Querying NoSQL Databases
- Couchbase Client API
- MongoDB Client API
- Camel Integration
- Consuming Files with Camel
- Receiving Messages from Kafka
- Java 8 Streams and CompletableFuture
- Usefulness of Parallel Streams
- Choosing the Appropriate Concurrency Abstraction
- When to Choose Observable?
- Memory Consumption and Leaks
- Operators Consuming Uncontrolled Amounts of Memory
- Summary
- Chapter 9. Future Directions
- Reactive Streams
- Observable and Flowable
- Performance
- Migration
- Appendix A. More HTTP Server Examples
- fork() Procedure in C Language
- Thread per Connection
- Thread Pool of Connections
- Appendix B. A Decision Tree of Observable Operators
- Index
- About the Authors
- Colophon
