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

Spring Data repositories

The Repository is the central interface in the Spring Data repositories which manages the domain class and the ID type of that particular domain class. The main task of the interface is to find types to work with for handling data and help the developers to discover all those interfaces which extend the Repository interface.

The CrudRepository interface extends the Repository interface, and facilitates handling CRUD functionalities to deal with the database. The following table explains the methods facilitating the CRUD operations provided by the CrudRepository interface:

Name of the method	Operations the method handles
`count()`	The `count()` method returns the number of entities available
`delete(ID id_delete)`	The `delete()` method facilitates deletion of the entity having the given ID
`delete(Iterable iterable_delete)`	This overloaded version of the...