Ruby gem by Kuba Suder that connects to the AT Protocol firehose (relay or jetstream) and dispatches every message to a registered callback. Built on EventMachine (Kuba mentions possibly rewriting it on async/io-uring). Used to filter commit messages for record operations — e.g. app.bsky.feed.post creates — and persist them to Postgres for network statistics or custom feed pipelines.