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