🎙️HttpChunk avec Flow
le 22 septembre 2025
Le traitement des réponses HTTP en chunks est un défi récurrent :
- Plusieurs requêtes doivent être lancées en parallèle.
- Certaines échouent (404, timeouts) et nécessitent des retries.
- Chaque utilisateur renvoie des données additionnelles (todos, posts), impliquant des requêtes « fan-out ».
- Le tout s’accumule rapidement en callback hell, gestion d’état manuelle, et tests difficiles.
Problématique :
HTTP chunk processing is complex when it should be fluid.
Le problème
En PHP, la gestion de flux HTTP asynchrones a souvent été abordée de manière impérative :
- Callbacks imbriqués.
- Variables d’état partagées.
- Difficultés de test et de maintenance.
Ces approches rendent le code peu lisible, fragile et coûteux à faire évoluer.
La solution avec Flow
Le Flow Framework apporte une réponse fonctionnelle et élégante à cette complexité.
- Jobs : des fonctions pures qui transforment des données.
- Ips : des objets immuables qui transportent l’information entre les jobs.
- Drivers : Amp, React, Swoole ou Fiber — abstraits derrière Flow.
- Y-Flow : l’intégration du Y-Combinator pour gérer la récursion sans boucles explicites.
RĂ©sultat : un pipeline clair, composable et testable, qui orchestre naturellement les flux asynchrones.
La démo : httpchunkflow.php
L’exemple concret :
php examples/httpchunkflow.php
DĂ©roulement :
- Trois requĂŞtes initiales (
/users,/users/404,/todos). - Gestion des erreurs : un 404 est automatiquement retry vers
/users/1. - Y-Combinator : chaque utilisateur déclenche automatiquement des requêtes supplémentaires (
/todos,/posts). - Exécution concurrente : les requêtes s’exécutent en parallèle.
- Merge final : consolidation des données en un résultat structuré.
Extrait de logs :
*. #1 GET /users ... started
*. #2 GET /users/404 ... started
*. #3 GET /todos ... started
.* #2 404 -> retry /users/1
..* #1 chunks: parsing via Y
...* #101 QUEUED /users/1/todos
...* #1101 QUEUED /users/1/posts
.* #101 200 in 18ms
.* #1101 200 in 16ms
....* merging data
.....* finalizing results
User #1: Leanne Graham ([email protected])
- Todos: 20 items
- Posts: 10 items
DONE driver=Flow\Driver\AmpDriver duration=7.99s users=200 retry=1 errors=0
Les bénéfices
- ✅ Lisibilité : plus de callback hell.
- ✅ Pureté : chaque job est une fonction testable isolément.
- ✅ Immutabilité : flux de données clairs et prévisibles.
- ✅ Récursion élégante : Y-Combinator au lieu de boucles impératives.
- âś… Async par design : Flow orchestre la concurrence naturellement.
Conclusion
Avec Flow et Y-Combinator, le traitement HTTP chunké passe d’un cauchemar impératif à une solution fluide et fonctionnelle. On obtient du code :
- plus lisible,
- plus testable,
- plus maintenable.