PHPackages amphp/parser - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. [Queues & Workers](/categories/queues) 4. / 5. amphp/parser ActiveLibrary[Queues & Workers](/categories/queues) amphp/parser ============ A generator parser to make streaming parsers simple. v1.1.1(2y ago)15052.8M—3.8%4[1 issues](https://github.com/amphp/parser/issues)14MITPHPPHP >=7.4CI failing Since Jun 6Pushed 2y ago6 watchersCompare [ Source](https://github.com/amphp/parser)[ Packagist](https://packagist.org/packages/amphp/parser)[ Docs](https://github.com/amphp/parser)[ GitHub Sponsors](https://github.com/amphp)[ RSS](/packages/amphp-parser/feed)WikiDiscussions 1.x Synced 1mo ago READMEChangelog (3)Dependencies (3)Versions (4)Used By (14) amphp/parser ============ [](#amphpparser) AMPHP is a collection of event-driven libraries for PHP designed with fibers and concurrency in mind. `amphp/parser` allows easily building streaming generator parsers. Installation ------------ [](#installation) This package can be installed as a [Composer](https://getcomposer.org/) dependency. ``` composer require amphp/parser ``` Requirements ------------ [](#requirements) - PHP 7.4+ Usage ----- [](#usage) PHP's generators are a great way for building incremental parsers. Example ------- [](#example) This simple parser parses a line delimited protocol and prints a message for each line. Instead of printing a message, you could also invoke a data callback. ``` $parser = new Parser((function () { while (true) { $line = yield "\r\n"; if (trim($line) === "") { continue; } print "New item: {$line}" . PHP_EOL; } })()); for ($i = 0; $i < 100; $i++) { $parser->push("bar\r"); $parser->push("\nfoo"); } ``` Furthere examples can be found in other AMPHP packages which this library to build streaming parsers. - [`ChannelParser`](https://github.com/amphp/byte-stream/blob/5c7eb399b746a582e9598935b26483b214250c34/src/Internal/ChannelParser.php#L28) in [`amphp/byte-stream`](https://github.com/amphp/byte-stream) - [`RespParser`](https://github.com/amphp/redis/blob/649cff6d5e6b4c579dcab1a20511a437cbe3d62a/src/Connection/RespParser.php#L31) in [`amphp/redis`](https://github.com/amphp/redis) Yield Behavior -------------- [](#yield-behavior) You can either `yield` a `string` that's used as delimiter, an `integer` that's used as length, or `null` to flush any remaining buffer in the parser (if any) or await the next call to `Parser::push()`. Versioning ---------- [](#versioning) `amphp/parser` follows the [semver](http://semver.org/) semantic versioning specification like all other `amphp` packages. Security -------- [](#security) If you discover any security related issues, please email [`me@kelunik.com`](mailto:me@kelunik.com) instead of using the issue tracker. License ------- [](#license) The MIT License (MIT). Please see [`LICENSE`](./LICENSE) for more information. ### Health Score 48 — FairBetter than 95% of packages Maintenance20 Infrequent updates — may be unmaintained Popularity65 Solid adoption and visibility Community28 Small or concentrated contributor base Maturity65 Established project with proven stability Bus Factor1 Top contributor holds 65.9% of commits — single point of failure How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~827 days Total 4 Last Release 788d ago PHP version history (2 changes)v1.0.0PHP >=7 v1.1.0PHP >=7.4 ### Community Maintainers ![](https://avatars.githubusercontent.com/u/1628287?v=4)[Aaron Piotrowski](/maintainers/Trowski)[@trowski](https://github.com/trowski) ![](https://www.gravatar.com/avatar/12852217f3369e8144bc9ce6ac2a2341c28c5512c5b3df5749bfbbd45b6877ff?d=identicon)[kelunik](/maintainers/kelunik) ![](https://www.gravatar.com/avatar/f6db63ad594446f67d79532b75c69439fd0df779cc90868b43c187c02a4221ef?d=identicon)[bwoebi](/maintainers/bwoebi) --- Top Contributors [![kelunik](https://avatars.githubusercontent.com/u/2743004?v=4)](https://github.com/kelunik "kelunik (29 commits)")[![trowski](https://avatars.githubusercontent.com/u/1628287?v=4)](https://github.com/trowski "trowski (13 commits)")[![nicolas-grekas](https://avatars.githubusercontent.com/u/243674?v=4)](https://github.com/nicolas-grekas "nicolas-grekas (1 commits)")[![peter279k](https://avatars.githubusercontent.com/u/9021747?v=4)](https://github.com/peter279k "peter279k (1 commits)") --- Tags parserphpstreamstreamasyncnon-blockingparser ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/amphp-parser/health.svg) ``` [![Health](https://phpackages.com/badges/amphp-parser/health.svg)](https://phpackages.com/packages/amphp-parser) ``` ### Alternatives [amphp/amp A non-blocking concurrency framework for PHP applications. 4.4k123.4M323](/packages/amphp-amp)[amphp/byte-stream A stream abstraction to make working with non-blocking I/O simple. 393116.2M104](/packages/amphp-byte-stream)[react/socket Async, streaming plaintext TCP/IP and secure TLS socket server and client connections for ReactPHP 1.3k116.9M402](/packages/react-socket)[workerman/phpsocket.io A server side alternative implementation of socket.io in PHP based on Workerman 2.3k578.6k16](/packages/workerman-phpsocketio)[revolt/event-loop Rock-solid event loop for concurrent PHP applications. 92343.6M138](/packages/revolt-event-loop)[amphp/socket Non-blocking socket connection / server implementations based on Amp and Revolt. 26539.0M119](/packages/amphp-socket) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)