PHPackages                             phalanx/stream - 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. phalanx/stream

ActiveLibrary[Queues & Workers](/categories/queues)

phalanx/stream
==============

Reactive stream primitives for Phalanx

v0.2.0(1mo ago)01↑2900%4MITPHPPHP ^8.4

Since Mar 23Pushed 1mo agoCompare

[ Source](https://github.com/havy-tech/phalanx-stream)[ Packagist](https://packagist.org/packages/phalanx/stream)[ Docs](https://github.com/havy-tech/phalanx-stream)[ RSS](/packages/phalanx-stream/feed)WikiDiscussions main Synced 1mo ago

READMEChangelogDependencies (5)Versions (3)Used By (4)

 [![Phalanx](brand/logo.svg)](brand/logo.svg)

Phalanx Stream
==============

[](#phalanx-stream)

Reactive streams that bridge push-based sources into pull-based fiber iteration. WebSocket frames, SSE events, file tails, timers--they all become composable pipelines you consume with `foreach`.

Table of Contents
-----------------

[](#table-of-contents)

- [Installation](#installation)
- [Quick Start](#quick-start)
- [Creating Streams](#creating-streams)
    - [Custom Producers](#custom-producers)
    - [ReadableStream Sources](#readablestream-sources)
    - [Event Emitter Sources](#event-emitter-sources)
    - [Interval Streams](#interval-streams)
- [Operators](#operators)
- [Terminal Operations](#terminal-operations)
- [Backpressure](#backpressure)
- [Scoped Streams](#scoped-streams)
- [Lifecycle Hooks](#lifecycle-hooks)

Installation
------------

[](#installation)

```
composer require phalanx/stream
```

Requires PHP 8.4+.

Quick Start
-----------

[](#quick-start)

```