Sign In Start Free Trial

PHP Reactive Programming

By : Sikora

2 (1)

PHP Reactive Programming

2 (1)

By: Sikora

Overview of this book

Reactive Programming helps us write code that is concise, clear, and readable. Combining the power of reactive programming and PHP, one of the most widely used languages, will enable you to create web applications more pragmatically. PHP Reactive Programming will teach you the benefits of reactive programming via real-world examples with a hands-on approach. You will create multiple projects showing RxPHP in action alone and in combination with other libraries. The book starts with a brief introduction to reactive programming, clearly explaining the importance of building reactive applications. You will use the RxPHP library, built a reddit CLI using it, and also re-implement the Symfony3 Event Dispatcher with RxPHP. You will learn how to test your RxPHP code by writing unit tests. Moving on to more interesting aspects, you will implement a web socket backend by developing a browser game. You will learn to implement quite complex reactive systems while avoiding pitfalls such as circular dependencies by moving the RxJS logic from the frontend to the backend. The book will then focus on writing extendable RxPHP code by developing a code testing tool and also cover Using RxPHP on both the server and client side of the application. With a concluding chapter on reactive programming practices in other languages, this book will serve as a complete guide for you to start writing reactive applications in PHP.

Preface

Preface

What this book covers

What you need for this book

Who this book is for

Conventions

Reader feedback

Customer support

Free Chapter

1. Introduction to Reactive Programming

1. Introduction to Reactive Programming

Imperative programming

Declarative programming

Sequential and parallel programming

Asynchronous programming

Functional programming

Reactive programming

Reactive Extensions

Introducing RxPHP

Summary

2. Reactive Programming with RxPHP

2. Reactive Programming with RxPHP

Basic principles of Reactive Extensions

Naming conventions in Reactive Extensions

Components of RxPHP

Writing the DebugSubject class

Writing JSONDecodeOperator

Writing CURLObservable

The proc_open() and non-blocking fread()

Event loop and RxPHP

Summary

3. Writing a Reddit Reader with RxPHP

3. Writing a Reddit Reader with RxPHP

Examining RxPHP's internals

Observable::create() and Observable::defer()

Writing a Reddit reader using RxPHP

Non-blocking CURLObservable

Types of disposable classes

Summary

4. Reactive versus a Typical Event-Driven Approach

4. Reactive versus a Typical Event-Driven Approach

Handling error states in operator chains

The concat() and merge() operators

Writing a reactive event dispatcher

Summary

5. Testing RxPHP Code

5. Testing RxPHP Code

The doOn*() operators

Installing the PHPUnit package

Basics of writing tests using PHPUnit

Testing RxPHP code

Testing SumOperator

Testing ForkJoinObservable

Summary

6. PHP Streams API and Higher-Order Observables

6. PHP Streams API and Higher-Order Observables

Using Promises in PHP

PHP Streams API

Higher-order Observables

Summary

7. Implementing Socket IPC and WebSocket Server/Client

7. Implementing Socket IPC and WebSocket Server/Client

Backpressure in Reactive Extensions

Implementing ProcessObservable

Server Manager application

Server Manager and the Unix socket server

Implementing a WebSocket server

Implementing a WebSocket client

Summary

8. Multicasting in RxPHP and PHP7 pthreads Extension

8. Multicasting in RxPHP and PHP7 pthreads Extension

Subjects

Multicasting in RxPHP

PHP pthreads extension

RxPHP and pthreads

Summary

9. Multithreaded and Distributed Computing with pthreads and Gearman

9. Multithreaded and Distributed Computing with pthreads and Gearman

Introduction to the PHP Parser library

Implementing ThreadPoolOperator

Introduction to Gearman

Summary

10. Using Advanced Operators and Techniques in RxPHP

10. Using Advanced Operators and Techniques in RxPHP

The zip() operator

The window() operator

The materialize() and dematerialize() operators

Error handling in RxPHP operator chains

The Observable::create() method versus the Subject class

Call stack length and EventLoopScheduler

Unsubscribing versus completing an Observable

Anonymous operators

Writing a custom DirectoryIteratorObservable

FTP client with RxPHP

Summary

Appendix. Reusing RxPHP Techniques in RxJS

Appendix. Reusing RxPHP Techniques in RxJS

What is RxJS?

A quick introduction to RxJS 5 in Node.js

Higher-order Observables in RxJS 5 and RxPHP

Operators specific for RxJS 5

Summary

Customer Reviews

2 (1)

5 star

0

4 star

0

3 star

0

2 star

100%

1 star

0

The doOn*() operators

In the previous chapter, we've used the map() operator a couple of times to just print to the console what's happening inside our Observable chains. However, this isn't very convenient. The map() operator always needs to return a value that is passed further down the chain, and it can catch only onNext signals.

That's why RxPHP has a couple of operators with the common prefix doOn*:

doOnNext(), doOnError(), doOnCompleted(): Each of these operators takes a callable as a parameter that is executed when they receive their respective signal
doOnEach(): This operator takes an instance of ObserverInterface as a parameter and executes its handlers for each signal

So these operators are very similar to the methods subscribeCallback() and subscribe(). The biggest advantage is in the way doOn* operators work internally. They never modify the value going through and just execute our callables, which is ideal for quickly...

Search

Your notes and bookmarks