Skip to content

Carefully crafted library to operate with continuous streams of data in a reactive style with publish/subscribe, asyncio support and broker functionality.

active 2023-08-182026-04-14 (UTC)

Complete coverage26,454 / 26,454 hourly files (100%) · 2 absent upstream2023-08-152026-08-21 (UTC)
Events
60
Pushes
12
Pull requests
9
Issues
9
Stars
5
Forks
2

Activity over time

Daily event counts in the loaded window

Line chart, 971 days from 2023-08-18 to 2026-04-14. Pushes: 12 total, peak 5 in a day. Pull requests: 9 total, peak 2 in a day. Issues: 9 total, peak 3 in a day. Comments: 9 total, peak 2 in a day. Stars: 5 total, peak 1 in a day.

  • Pushes
  • Pull requests
  • Issues
  • Comments
  • Stars

Stars, PRs, issues and forks are under-captured in the later part of this window. GH Archive progressively stopped capturing non-push events during 2026 — −95% or worse by the end of the window. Every series here except Pushes fades for that reason, so a decline above reflects the archive, not this repository. Pushes stay reliable throughout, so read them, and the contributor counts derived from them, as the real signal. Data health has the measurements.

Top contributors

Pushes, PRs, issues, reviews and comments — stars and forks excluded, so this is contribution rather than popularity

ContributorContributionsPushesPRsComments
semiversus261137
phettberg6121
dependabot[bot]3030
flofeurstein3011
lki13541000

Recent activity

Latest issues, pull requests and releases

  • Issue#52semiversus2026-02-12 14:41
    Limit SinkAsync coro queue
  • Issue#54semiversus2026-02-12 14:41
    Outdated tooling and support of Python >= 3.12
  • Pull request#53phettberg2026-02-12 14:08
  • Issue comment#54semiversus2026-02-12 08:55
    Outdated tooling and support of Python >= 3.12
  • Issue comment#53phettberg2026-02-11 17:31
    Add max queue size functionality to CoroQueue and related components
  • Issue comment#52semiversus2026-02-09 16:55
    Limit SinkAsync coro queue
  • Issue#52phettberg2026-02-09 11:51
    Limit SinkAsync core queue
  • Pull request#51dependabot[bot]2026-01-22 18:23
  • Pull request#51dependabot[bot]2026-01-22 18:23
  • Pull request#50dependabot[bot]2025-09-04 15:47
  • Releasesemiversus2025-04-08 14:51
    3.1.1
  • Pull request#49semiversus2025-04-08 14:21
  • Pull request#49flofeurstein2025-04-08 13:25
  • Releasesemiversus2025-04-03 13:04
    3.1.0
  • Issue comment#39semiversus2025-04-03 11:54
    Any not working when a publisher has state NONE
  • Issue#39semiversus2025-04-03 11:54
    Any not working when a publisher has state NONE
  • Issue comment#47semiversus2025-04-03 11:53
    emit partial state of combine latest
  • Issue#47semiversus2025-04-03 11:53
    emit partial state of combine latest
  • Pull request#48semiversus2025-04-03 11:53
  • Issue#47flofeurstein2025-04-03 09:56
    emit partial state of combine latest
  • Releasesemiversus2024-01-18 20:33
    3.0.3
  • Issue#45semiversus2024-01-18 20:30
    SinkAsync does not use the error_callback
  • Pull request#46semiversus2024-01-18 20:30
  • Issue comment#46semiversus2024-01-18 20:30
    Fix missing error_callback call in SinkAsync
  • Pull request#46phettberg2024-01-18 19:23

Totals cover only the window loaded into ClickHouse and count events, not GitHub's lifetime totals — 5 stars here means stars gained during the window, not the repo's star count.