Browse Library
Sign In Start Free Trial
Close icon Search icon
Account
Browse Library Advanced Search Sign In Start Free Trial

Add to playlist

Create a Playlist

Modal Close icon
You need to login to use this feature.
  • Book Overview & Buying PHP Reactive Programming
  • Table Of Contents Toc
  • Feedback & Rating feedback
PHP Reactive Programming

PHP Reactive Programming

By : Sikora
2 (1)
Buy this Book
close
close
PHP Reactive Programming

PHP Reactive Programming

2 (1)
By: Sikora
Buy this Book

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.
Table of Contents (12 chapters)
close
close
close
Preface
Icon
Preface
Icon
What this book covers
Icon
What you need for this book
Icon
Who this book is for
Icon
Conventions
Icon
Reader feedback
Icon
Customer support
Free Chapter
1
1. Introduction to Reactive Programming
Icon
1. Introduction to Reactive Programming
Icon
Imperative programming
Icon
Declarative programming
Icon
Sequential and parallel programming
Icon
Asynchronous programming
Icon
Functional programming
Icon
Reactive programming
Icon
Reactive Extensions
Icon
Introducing RxPHP
Icon
Summary
2
2. Reactive Programming with RxPHP
chevron up
Icon
2. Reactive Programming with RxPHP
Icon
Basic principles of Reactive Extensions
Icon
Naming conventions in Reactive Extensions
Icon
Components of RxPHP
Icon
Writing the DebugSubject class
Icon
Writing JSONDecodeOperator
Icon
Writing CURLObservable
Icon
The proc_open() and non-blocking fread()
Icon
Event loop and RxPHP
Icon
Summary
3
3. Writing a Reddit Reader with RxPHP
Icon
3. Writing a Reddit Reader with RxPHP
Icon
Examining RxPHP's internals
Icon
Observable::create() and Observable::defer()
Icon
Writing a Reddit reader using RxPHP
Icon
Non-blocking CURLObservable
Icon
Types of disposable classes
Icon
Summary
4
4. Reactive versus a Typical Event-Driven Approach
Icon
4. Reactive versus a Typical Event-Driven Approach
Icon
Handling error states in operator chains
Icon
The concat() and merge() operators
Icon
Writing a reactive event dispatcher
Icon
Summary
5
5. Testing RxPHP Code
Icon
5. Testing RxPHP Code
Icon
The doOn*() operators
Icon
Installing the PHPUnit package
Icon
Basics of writing tests using PHPUnit
Icon
Testing RxPHP code
Icon
Testing SumOperator
Icon
Testing ForkJoinObservable
Icon
Summary
6
6. PHP Streams API and Higher-Order Observables
Icon
6. PHP Streams API and Higher-Order Observables
Icon
Using Promises in PHP
Icon
PHP Streams API
Icon
Higher-order Observables
Icon
Summary
7
7. Implementing Socket IPC and WebSocket Server/Client
Icon
7. Implementing Socket IPC and WebSocket Server/Client
Icon
Backpressure in Reactive Extensions
Icon
Implementing ProcessObservable
Icon
Server Manager application
Icon
Server Manager and the Unix socket server
Icon
Implementing a WebSocket server
Icon
Implementing a WebSocket client
Icon
Summary
8
8. Multicasting in RxPHP and PHP7 pthreads Extension
Icon
8. Multicasting in RxPHP and PHP7 pthreads Extension
Icon
Subjects
Icon
Multicasting in RxPHP
Icon
PHP pthreads extension
Icon
RxPHP and pthreads
Icon
Summary
9
9. Multithreaded and Distributed Computing with pthreads and Gearman
Icon
9. Multithreaded and Distributed Computing with pthreads and Gearman
Icon
Introduction to the PHP Parser library
Icon
Implementing ThreadPoolOperator
Icon
Introduction to Gearman
Icon
Summary
10
10. Using Advanced Operators and Techniques in RxPHP
Icon
10. Using Advanced Operators and Techniques in RxPHP
Icon
The zip() operator
Icon
The window() operator
Icon
The materialize() and dematerialize() operators
Icon
Error handling in RxPHP operator chains
Icon
The Observable::create() method versus the Subject class
Icon
Call stack length and EventLoopScheduler
Icon
Unsubscribing versus completing an Observable
Icon
Anonymous operators
Icon
Writing a custom DirectoryIteratorObservable
Icon
FTP client with RxPHP
Icon
Summary
Appendix. Reusing RxPHP Techniques in RxJS
Icon
Appendix. Reusing RxPHP Techniques in RxJS
Icon
What is RxJS?
Icon
A quick introduction to RxJS 5 in Node.js
Icon
Higher-order Observables in RxJS 5 and RxPHP
Icon
Operators specific for RxJS 5
Icon
Summary

Writing the DebugSubject class

One common use case for Subject class is proxying all values and notifications from its source Observable.

In one of the preceding paragraphs, we wrote the PrintObserver class, which prints all values it receives. However, a more common situation is where we want to output values from an Observable while being able to chain it with another operator or observer. The Subject class exactly fits this use case, so we'll rewrite the preceding PrintObserver class and inherit Subject instead of AbstractObserver:

class DebugSubject extends Rx\Subject\Subject { 
  public function __construct($identifier=null, $maxLen=64){ 
    $this->identifier = $identifier; 
    $this->maxLen = $maxLen; 
  } 
  public function onCompleted() { 
    printf("%s%s onCompleted\n", $this->getTime(), $this->id());
    parent::onCompleted(); 
  }  
  public function onNext($val) { 
    $type = is_object($val) ? get_class($val) : gettype($val); 
 
 ...

Unlock full access

Continue reading for free

A Packt free trial gives you instant online access to our library of over 7000 practical eBooks and videos, constantly updated with the latest in tech
Start a 7-day FREE trial
End of Section 5
Next Section

Create a Note

Modal Close icon
You need to login to use this feature.
notes
bookmark search playlist download
font-size

Change the font size

margin-width

Change margin width

day-mode

Change background colour

Close icon Search
Country selected
Close icon Your notes and bookmarks

Delete Bookmark

Modal Close icon
Are you sure you want to delete it?
Cancel
Yes, Delete

Delete Note

Modal Close icon
Are you sure you want to delete it?
Cancel
Yes, Delete

Edit Note

Modal Close icon
Write a note (max 255 characters)
Cancel
Update Note

Confirmation

Modal Close icon
claim successful
Order Page Read Now

Buy this book with your credits?

Modal Close icon
Are you sure you want to buy this book with one of your credits?
Close
YES, BUY