A back-pressured backfill executor for Ecto.

An open source two way communication platform for the social sector

Elixir GenStage front-end for Redis Streams

Elixir websockets library and utilities for Bitshares/Graphene 2.0 blockchain

GenStage wrapper for simplifying event consumption and production

Handy little queues and producers.

The Brains of the Farmbot Project

Marketo REST api client

Cashier is an Elixir library that aims to be an easy to use payment gateway, whilst offering the fault tolerance and scalability benefits...

An event_bus data store building with Broadway.

An Off-Broadway producer enabling real-time ingestion of WebSocket data.

Hardware Abstraction Layer for Nerves Devices

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

ExOSC is a library for sending and receiving messages to/from audio hardware that supports the OpenSoundControl 1.0 protocol.

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

Hemdal Alarms/Alerts System

A User Management system for Elixir Projects

A BitTorrent library.

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

Elixir GenServer and GenStage runtime metrics.

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

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

Elixir package for communicating with 32-bit Numato GPIO module

A Batch elixir client

A GenStage dispatcher to route events based on some notion of locality

A MQTT connector for Broadway

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

Make announcements to torrent trackers via HTTP or UDP.

A Posthog SDK

WIP - Stream data from enumerables in a controller manner!