You're reading from PHP Reactive Programming Build fault tolerant and high performing application in PHP based on the reactive architecture

Product type Paperback

Published in Mar 2017

Last Updated in Feb 2025

Publisher Packt

ISBN-13 9781786462879

Length 364 pages

Edition 1st Edition

Languages

PHP

Tools

Composer

Concepts

Reactive Programming

Author (1):

Sikora

View More author details

Table of Contents (12) Chapters

Preface

1. Introduction to Reactive Programming FREE CHAPTER

2. Reactive Programming with RxPHP

3. Writing a Reddit Reader with RxPHP

4. Reactive versus a Typical Event-Driven Approach

5. Testing RxPHP Code

6. PHP Streams API and Higher-Order Observables

7. Implementing Socket IPC and WebSocket Server/Client

8. Multicasting in RxPHP and PHP7 pthreads Extension

9. Multithreaded and Distributed Computing with pthreads and Gearman

10. Using Advanced Operators and Techniques in RxPHP

Appendix. Reusing RxPHP Techniques in RxJS

Chapter 6. PHP Streams API and Higher-Order Observables

In this chapter, we'll introduce a lot of new features that we need for the next chapter. Almost everything covered in this chapter is related to PHP Streams API, Promises and event loops (reactphp/event-loop project in our case). This also includes a couple of more advanced RxPHP operators working with so-called higher-order Observables.

In particular, in this chapter, we'll do the following:

Quickly look at using Promises in PHP with the reactphp/promise library
Introduce PHP Streams API and, with examples, see what benefits it brings with minimal or no effort
Examine the internals of StreamSelectLoop class, this time in the context of PHP Streams API
See what caveats we need to be aware of when working with non-blocking code in event loops
Talk about higher-order Observables
Introduce four new and more advanced operators, concatAll(), mergeAll(), combineLatest() and switchMap(), which are...