Book Image

Reactive Programming With Java 9

By : Tejaswini Mandar Jog

Book Image

Reactive Programming With Java 9

By: Tejaswini Mandar Jog

Overview of this book

<p>Reactive programming is an asynchronous programming model that helps you tackle the essential complexity that comes with writing such applications.</p> <p>Using Reactive programming to start building applications is not immediately intuitive to a developer who has been writing programs in the imperative paradigm. To tackle the essential complexity, Reactive programming uses declarative and functional paradigms to build programs. This book sets out to make the paradigm shift easy.</p> <p>This book begins by explaining what Reactive programming is, the Reactive manifesto, and the Reactive Streams specifi cation. It uses Java 9 to introduce the declarative and functional paradigm, which is necessary to write programs in the Reactive style. It explains Java 9’s Flow API, an adoption of the Reactive Streams specifi cation. From this point on, it focuses on RxJava 2.0, covering topics such as creating, transforming,fi ltering, combining, and testing Observables. It discusses how to use Java’s popular framework, Spring, to build event-driven, Reactive applications. You will also learn how to implement resiliency patterns using Hystrix. By the end, you will be fully equipped with the tools and techniques needed to implement robust, event-driven, Reactive applications.</p>

Preface

What this book covers

What you need for this book

Who this book is for

Reader feedback

Customer support

Free Chapter

Introduction to Reactive Programming

Introduction to Reactive Programming

Asynchronous programming

Programming Paradigm Shift

Programming Paradigm Shift

Programming paradigm

Functional programming

Declarative programming

Operator fusion

Reactive Streams

Reactive Streams

Discussing the Collection framework

Understanding backpressure

Reactive Types in RxJava

Reactive Types in RxJava

Observer design pattern

The Iterator design pattern

Hot or cold Observables

Creating Observable emitting sequential data

Transforming Rx non-compatible sequences into Observables

Creating Observables for unrestricted infinite length

Types of observables

Understanding the Disposable interface

Operators

Demystifying RxMarbles using an Observable

Transforming Observables using operators

Filtering Observable

Combining Observables

Conditional operators

The mathematical and aggregate operators

Building Responsiveness

Building Responsiveness

Building Resiliency

Building Resiliency

Error handling in RxJava

Exceptions specific to RxJava

Testing

Testing the need and role of a developer

The traditional way of testing an Observable

The modern approach for testing an Observable

Testing the Subscriber

The test() operator

Testing notifications

Mockito testing

Spring Reactive Web

Spring Reactive Web

An introduction to Spring Framework

The Spring architecture

Project Reactor

Spring web Reactive Programming

Server-side support

Server-Sent Events (SSE)

Implementing Resiliency Patterns Using Hystrix

Implementing Resiliency Patterns Using Hystrix

Hystrix- an introduction

Demonstrating HystrixObservableCommand

Handling fallback

Design patterns in resiliency

Queue-based load leveling pattern

Patterns used by Hystrix

Request collapsing or request batching

Request caching

Reactive Data Access

Reactive Data Access

Spring Data repositories

Spring Data and Reactive Programming

Spring Data Reactive and Redis

Running the Kafka application

Customer Reviews

5 star

0

4 star

0

3 star

0

2 star

0

1 star

0

Functional programming

"Any fool can write code that a computer can understand. Good programmers write code that humans can understand."

- Martin Fowler

The preceding statement is the essence of functional programming.

A function is a basic building block of code which helps in evaluating mathematical expressions. The style puts emphasis on the expressions. In functional programming functions are the first class values, enabling them to pass as an argument to other functions. Also, they can be returned from the function as a result. In functional programming, the result of the expression after the evaluation is completely dependent upon the arguments which have been passed to the function and have not dealt with...