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.
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
— 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
— 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
— Handling error states in operator chains
— The concat() and merge() operators
— Writing a reactive event dispatcher
— Summary
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
— Using Promises in PHP
— PHP Streams API
— Higher-order Observables
— Summary
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
— Subjects
— Multicasting in RxPHP
— PHP pthreads extension
— RxPHP and pthreads
— Summary
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
— 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
11: 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
