PHPackages                             togos/phpipeable - 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. [Framework](/categories/framework)
4. /
5. togos/phpipeable

ActiveLibrary[Framework](/categories/framework)

togos/phpipeable
================

A PHP framework for modeling data flows in a reactive-ish way, similar to Node streams

1.5.4(7y ago)036MITPHPPHP >=5.2

Since Feb 12Pushed 7y agoCompare

[ Source](https://github.com/TOGoS/PHPipeable)[ Packagist](https://packagist.org/packages/togos/phpipeable)[ RSS](/packages/togos-phpipeable/feed)WikiDiscussions master Synced 2d ago

READMEChangelogDependencies (1)Versions (13)Used By (0)

PHPipeable
==========

[](#phpipeable)

Provides a lightweight framework for push-based stream processing.

```
$someDataSource = new SomethingThatImplementsPipeable();
$someDataSink = new SomethingThatImplementsSink();
$someDataSource->pipe($someDataSink);

// Our pipe system is now in place,
// so shove some data through:

$someDataSource->emitSomeStuff(); // Use imagination here
$results = $someDataSource->emitClose(); // Let everyone know that's all,
                                         // and collect feedback from sinks

```

Philosophical notes about the Sink interface
--------------------------------------------

[](#philosophical-notes-about-the-sink-interface)

For reference:

```
interface TOGoS_PHPipeable_Sink
{
	function open(array $fileInfo=array());
	function item($item, array $metadata=array());
	function close(array $info=array());
	// __invoke(...) should be like item(...)
}

```

An alterntive approach would be to have an even simpler definition for the sink interface such as 'a 1-ary function'. Open and close events would be passed to the function using the same mechanism as data items (this is how [EIT's logging framework](https://github.com/EarthlingInteractive/PHPLogging) is defined).

A disadvantage to that approach is that your data items then need to be wrapped in some kind of object to distinguish them from stream metadata, which adds complexity to the code that implements and uses the sink.

The more complex sink interface maps more nicely to the use cases that I'm concerned with today, which are importing and transforming CSV files. Breaking out open(...) item(...) and end(...) calls gives some guidance about the meaning of metadata and the order in which they should be called, freeing implementing classes from having to define those things.

`close(...)` marks a point at which to commit any changes and is a convenient way to get information from deeply nested sinks back to the caller.

###  Health Score

28

—

LowBetter than 52% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity7

Limited adoption so far

Community6

Small or concentrated contributor base

Maturity65

Established project with proven stability

 Bus Factor1

Top contributor holds 100% 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 ~17 days

Total

12

Last Release

2870d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/57142?v=4)[Dan Stevens](/maintainers/TOGoS)[@TOGoS](https://github.com/TOGoS)

---

Top Contributors

[![TOGoS](https://avatars.githubusercontent.com/u/57142?v=4)](https://github.com/TOGoS "TOGoS (21 commits)")

### Embed Badge

![Health badge](/badges/togos-phpipeable/health.svg)

```
[![Health](https://phpackages.com/badges/togos-phpipeable/health.svg)](https://phpackages.com/packages/togos-phpipeable)
```

###  Alternatives

[laravel/dusk

Laravel Dusk provides simple end-to-end testing and browser automation.

1.9k38.6M290](/packages/laravel-dusk)[nineinchnick/edatatables

Grid widget for the Yii Framework, wrapper for the DataTables jQuery plugin

173.2k](/packages/nineinchnick-edatatables)[link-cloud/fast-hyperf

LinkCloud Fast Hyperf

241.2k1](/packages/link-cloud-fast-hyperf)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)