Asynchronous Data Operators and Transformations | Reactive Programming in Kotlin

Sign In Start Free Trial

Book Overview & Buying
Table Of Contents
Feedback & Rating

Reactive Programming in Kotlin

By : Rivu Chakraborty

2.3 (3)

Reactive Programming in Kotlin

2.3 (3)

By: Rivu Chakraborty

Overview of this book

In today's app-driven era, when programs are asynchronous, and responsiveness is so vital, reactive programming can help you write code that's more reliable, easier to scale, and better-performing. Reactive programming is revolutionary. With this practical book, Kotlin 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. You will begin with the general concepts of Reactive programming and then gradually move on to working with asynchronous data streams. You will dive into advanced techniques such as manipulating time in data-flow, customizing operators and provider and how to use the concurrency model to control asynchronicity of code and process event handlers effectively. You will then be introduced to functional reactive programming and will learn to apply FRP in practical use cases in Kotlin. This book will also take you one step forward by introducing you to Spring 5 and Spring Boot 2 using Kotlin. By the end of the book, you will be able to build real-world applications with reactive user interfaces as well as you'll learn to implement reactive programming paradigms in Android.

Preface

Preface

What this book covers

What you need for this book

Who this book is for

Conventions

Reader feedback

Customer support

Free Chapter

A Short Introduction to Reactive Programming

A Short Introduction to Reactive Programming

What is reactive programming?

Reasons to adapt functional reactive programming

Reactive Manifesto

Getting started with RxKotlin

The ReactiveCalculator project

Summary

Functional Programming with Kotlin and RxKotlin

Functional Programming with Kotlin and RxKotlin

Introducing functional programming

Fundamentals of functional programming

Applying functional programming to the ReactiveCalculator class

Coroutines

Functional programming – monads

Summary

Observables, Observers, and Subjects

Observables, Observers, and Subjects

Observables

Other Observable factory methods

Hot and Cold Observables

Varieties of Subject

Summary

Introduction to Backpressure and Flowables

Introduction to Backpressure and Flowables

Understanding backpressure

Flowable

When to use Flowables and Observables

Flowable and Subscriber

Creating Flowable from scratch

Creating Flowable from Observable

BackpressureStrategy.MISSING and onBackpressureXXX()

Generating Flowable with backpressure at source

ConnectableFlowable

Processor

Learning Buffer, Throttle, and Window operators

Summary

Asynchronous Data Operators and Transformations

Asynchronous Data Operators and Transformations

Operator

The filtering/suppressing operators

The transforming operators

Reducing operators

The error handling operators

The utility operators

Summary

More on Operators and Error Handling

More on Operators and Error Handling

Combining producers (Observable/Flowable)

Grouping

flatMap, concatMap – In details

Understanding switchMap operator

Skipping and taking emissions

The error handling operators

onErrorReturn – return a default value on error

The onErrorResumeNext operator

An HTTP example

Summary

Concurrency and Parallel Processing in RxKotlin with Schedulers

Concurrency and Parallel Processing in RxKotlin with Schedulers

Introduction to concurrency

Parallel execution versus concurrency

What is a scheduler?

How to use schedulers – subscribeOn and observeOn operators

Summary

Testing RxKotlin Applications

Testing RxKotlin Applications

Introduction to unit testing and its importance

Writing JUnit tests in Kotlin

Testing in RxKotlin

Blocking subscribers

Blocking operators

Introducing TestObserver and TestSubscriber

Understanding TestScheduler

Summary

Resource Management and Extending RxKotlin

Resource Management and Extending RxKotlin

Resource management

Creating your own operators

Composing operators with transformer

Summary

Introduction to Web Programming with Spring for Kotlin Developers

Introduction to Web Programming with Spring for Kotlin Developers

Spring, history, and origin of Spring

Dependency injection and IoC

Spring – AOP

Introduction to Spring Boot

Creating a Rest API with Spring Boot

Summary

REST APIs with Spring JPA and Hibernate

REST APIs with Spring JPA and Hibernate

REST API with Spring Boot, Hibernate, and JPA

Reactive programming with Reactor

Summary

Reactive Kotlin and Android

Reactive Kotlin and Android

Setting up Kotlin in Android Studio

Getting started with ToDoApp on Android

Retrofit 2 for API calls

RxKotlin with Retrofit

Making Android events reactive

Kotlin extensions

Summary

Customer Reviews

2.3 (3)

5 star

33.3%

4 star

0%

3 star

0%

2 star

0%

1 star

66.7%

Reducing operators

While developing applications, you may face such a situation where you may need to accumulate and consolidate emissions. Note that nearly all the operators under this criteria will only work on a finite producer (Observable/Flowable) that calls onComplete() because typically, we can consolidate only finite datasets. We will explore this behavior as we cover these operators.

Here is a short list of reducing operators, which we will cover in this chapter:

count
reduce
all
any
contains

Counting emissions (count operator)

The count operator subscribes to a producer, counts the emissions, and emits a Single, containing the count of emissions by the producer.

Here is an example:

    fun main(args: Array<String>) { 
      listOf(1,5,9,7,6,4,3,2,4,6,9).toObservable() 
      .count() 
      .subscribeBy { println("count $it") } 
    }

The following is the output:

As we can see from the output, this operator counts the emissions from the producer, and emits the count once it receives...

Visually different images

CONTINUE READING

83

Tech Concepts

36

Programming languages

73

Tech Tools

Unlimited access to the largest independent learning library in tech of over 8,000 expert-authored tech books and videos.

Innovative learning tools, including AI book assistants, code context explainers, and text-to-speech.

50+ new titles added per month and exclusive early access to books as they are being written.

Reactive Programming in Kotlin

Search

Your notes and bookmarks