Reactive Programming in Kotlin by Chakraborty, Rivu -- Read -- Imperial Library of Trantor

Index

Title Page Copyright

Reactive Programming in Kotlin

Credits About the Author About the Reviewers www.PacktPub.com

Why subscribe?

Customer Feedback Dedication 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 Downloading the color images of this book Errata Piracy Questions

A Short Introduction to Reactive Programming

What is reactive programming? Reasons to adapt functional reactive programming Reactive Manifesto

Reactive Streams standard specifications Reactive Frameworks for Kotlin

Getting started with RxKotlin

Downloading and setting up RxKotlin Comparing the pull mechanism with the RxJava push mechanism The ReactiveEvenOdd program

The ReactiveCalculator project Summary

Functional Programming with Kotlin and RxKotlin

Introducing functional programming Fundamentals of functional programming

Lambda expressions Pure function High-order functions Inline functions

Applying functional programming to the ReactiveCalculator class Coroutines

Getting started with coroutines Building sequences The ReactiveCalculator class with coroutines

Functional programming – monads

Single monad

Summary

Observables, Observers, and Subjects

Observables

How Observable works

Understanding the Observable.create method Understanding the Observable.from methods Understanding the toObservable extension function Understanding the Observable.just method

Other Observable factory methods

Subscribers - the Observer interface Subscribing and disposing

Hot and Cold Observables

Cold Observables Hot Observables

Introducing the ConnectableObservable object Subjects

Varieties of Subject

Understanding AsyncSubject Understanding PublishSubject Understanding BehaviorSubject Understanding ReplaySubject

Summary

Introduction to Backpressure and Flowables

Understanding backpressure Flowable When to use Flowables and Observables

When to use Flowables? When to use Observables?

Flowable and Subscriber Creating Flowable from scratch Creating Flowable from Observable BackpressureStrategy.MISSING and onBackpressureXXX()

Operator onBackpressureBuffer() Operator onBackpressureDrop() Operator onBackpressureLatest()

Generating Flowable with backpressure at source ConnectableFlowable Processor Learning Buffer, Throttle, and Window operators

The buffer() operator The window() operator The throttle() operators

Summary

Asynchronous Data Operators and Transformations

Operator The filtering/suppressing operators

The debounce operator The distinct operators – distinct, distinctUntilChanged The elementAt operator Filtering emissions - filter operator The first and last operator The ignoreElements operator

The transforming operators

The map operator Casting emissions (cast operator) The flatMap operator The defaultIfEmpty operator The switchIfEmpty operator The startWith operator Sorting emissions (sorted operator) Accumulating data – scan operator

Reducing operators

Counting emissions (count operator) Accumulating emissions – reduce operator The collection operators

The error handling operators The utility operators Summary