PHPackages                             glider88/async-redis-streams - 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. [Caching](/categories/caching)
4. /
5. glider88/async-redis-streams

ActiveLibrary[Caching](/categories/caching)

glider88/async-redis-streams
============================

Redis Streams with TrueAsync

0.0.1(1mo ago)20MITPHPPHP ^8.6

Since Jun 12Pushed 1mo agoCompare

[ Source](https://github.com/Glider88/trueasync-redis-streams)[ Packagist](https://packagist.org/packages/glider88/async-redis-streams)[ RSS](/packages/glider88-async-redis-streams/feed)WikiDiscussions main Synced 1w ago

READMEChangelogDependencies (4)Versions (2)Used By (0)

TrueAsync redis streams realization
===================================

[](#trueasync-redis-streams-realization)

### Installation:

[](#installation)

```
composer require glider88/async-redis-streams
```

Start docker:

```
bin/re # first time
```

```
bin/up # next times
```

Tests:

```
bin/unit
```

### Run example:

[](#run-example)

Producer:

```
bin/php examples/producer.php
```

Consumer:

```
bin/php examples/consumer.php
```

### Settings:

[](#settings)

```
$config = new Config(
    redisUrl: 'redis://redis:6379',
    stream: 's',                                          // stream name
    group: 'g',                                           // consumer group name
    scaling: new PiecewiseLinearScaling([                 // complex scaling number of workers, for empty stream (< 500) use 16 worker, next 32
        12 => 0,
        32 => 500,
    ]),
    healthcheckInterval: new Sec(100),                     // redis health check interval
    maxStreamLength: 1000,                                 // approximate stream size
    maxDlqStreamLength: 1000,                              // approximate stream size for dead letters
    readRetrySetCount: 100,                                // how many entities we get at time from redis sorted set
    readAutoClaimCount: 100,                               // how many autoclaim entities we get at time
    blockRead: new Sec(1),                                 // how long we wait first data from stream
    deduplicationTtl: new Sec(3),                          // for deduplication logic used `SET $streamMessageId . '-' . $this->group` with this ttl
    autoClaimMinIdle: new Sec(2),                          // after this time we get message from PEL by autoclaim
    timeoutJob: new Sec(1),                                // timeout for job, after which we cancel it by TimeoutCancellation exception
    retryInterval: new Milli(100),                         // how often we launch retry logic
    maxRetries: 3,                                         // after we send message to dead letters stream (with s:dql name)
    retry: new MultiplyRetry(                              // retry with incremental increase time: 0 1 2 3... seconds wait before retry
        firstOffsetDelay: new Milli(0),
        baseDelay: new Sec(1),
    ),
    claimInterval: new Milli(100),                         // how often we launch autoclaim logic
    logger: new NullLogger(),
    minRedisWorkers: 1,                                    // Async\Pool: How many redis connections to create in advance (pre-warming)
    maxRedisWorkers: 100,                                  // Async\Pool: Maximum redis connections
    threadBootloader: static function () {                 // Async\Thread bootloader
        require  '/usr/src/app/examples/bootstrap.php';
        require  '/usr/src/app/vendor/autoload.php';
    },
    consumer: 'c'                                          // consumer name
);

$stream = new Stream($config);
```

###  Health Score

37

—

LowBetter than 81% of packages

Maintenance90

Actively maintained with recent releases

Popularity3

Limited adoption so far

Community6

Small or concentrated contributor base

Maturity41

Maturing project, gaining track record

 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

Unknown

Total

1

Last Release

46d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/1173406?v=4)[Pavel Sakharov](/maintainers/Glider88)[@Glider88](https://github.com/Glider88)

---

Top Contributors

[![Glider88](https://avatars.githubusercontent.com/u/1173406?v=4)](https://github.com/Glider88 "Glider88 (1 commits)")

---

Tags

streamredistrueasync

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/glider88-async-redis-streams/health.svg)

```
[![Health](https://phpackages.com/badges/glider88-async-redis-streams/health.svg)](https://phpackages.com/packages/glider88-async-redis-streams)
```

###  Alternatives

[rhubarbgroup/redis-cache

A persistent object cache backend for WordPress powered by Redis. Supports Predis, PhpRedis, Relay, replication, sentinels, clustering and WP-CLI.

527101.4k1](/packages/rhubarbgroup-redis-cache)[symfony-bundles/redis-bundle

Symfony Redis Bundle

291.2M7](/packages/symfony-bundles-redis-bundle)[pdffiller/qless-php

PHP Bindings for qless

29113.7k2](/packages/pdffiller-qless-php)[lion/bundle

Lion-framework configuration and initialization package

122.4k4](/packages/lion-bundle)

PHPackages © 2026

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