DataSource provides an infinite stream of data and DataStage provides a GenStage-producer you can subscribe to in order to fetch data/eve...

A Batch elixir client

build microservices with Kafka + Avro schemas

Elixir GenStage front-end for Redis Streams

A library for connecting to HLDS servers and using GenStage to produce structured log entries.

Provides helpers in Elixir to create GenStage, Exq, or AMQP based event queues and handlers

A distributed ECS (Entity-Component-System) framework in Elixir

Event Broadcaster (GenStage + Swarm)

Elixir HTTP/Websockets client library for official Steemit API and standard steemd JSONRPC interface. Includes module for pseudo realtime...

Elixir websockets library and utilities for GOLOS JSONRPC websocket interface

GenStage based interface for RabbitMQ

Webhook magic in Elixir

A logger backend for posting errors to Slack.

The Brains of the Farmbot Project

Flow-Based Programming with Elixir GenStage.

Twitter client library for Elixir

Alchemetrics is a wrapper around exometer, that uses GenStage to backpressure the reports.

An ECS (Entity-Component-System) framework in Elixir

Library for sending push notifications. Supports Apple APNS (with either ssl certificate or JWT) and Google FCM services.

tile38-server wrapper

Job Queue based on Genstage with retries, deduplication and replies.

Distributed `Agent` implementation, providing multi-node agents on top of Mnesia.

Subscribes GenStage consumers to producers across Elixir Umbrella apps.

Hivent is a messaging platform that makes it easy to build Reactive Microservice systems.

River is an http/2 (HTTP2) client for Elixir (a work in progress, though!)

Topic producer-consumer library built on top of GenStage for Elixir

Elixir GenStage that batches events together so they are not sent one-by-one

A simple Elixir web crawler library powered by GenStage.

An Elixir IRC module providing GenStage/callback based IRC Clients.

Elixir websockets library and utilities for Bitshares/Graphene 2.0 blockchain