Queue and Poller behaviours for Elixir Flow

Txbox is a Bitcoin transaction storage schema

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

Elasticsearch Elixir Bulk Processor is a configurable manager for efficiently inserting data into Elasticsearch. This processor uses gens...

Webhook magic in Elixir

An application you can use for benchmarking, read terms from a file (or other Producer) and execute them against an anonymous function of...

Download RSS/Atom feeds enclosures.

An OTP application for reading and parsing GPS data written in Elixir. Will attach to an serial port, and provide positions to subscriber...

A back-pressured backfill executor for Ecto.

A simple Elixir web crawler library powered by GenStage.

Klarna's Brod kafka client wrapped into GenStage.

Flow-Based Programming with Elixir GenStage.

Discord Library in Elixir.

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

Client library for the Particle Cloud API.

API client library for any MediaWiki-based site, such as Wikipedia or Wikimedia Commons. Provides the Action API, realtime feed ingestion...

Helper modules to connect an ELEMENT app with ELEMENT IoT

Library to validate and exchange messages

A client for sending and receiving messages on NKN

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

GenStage wrapper for simplifying event consumption and production

Transactional outbox for kafka

Socket framework for elixir.

An event_bus data store building with Broadway.

Marketo REST api client

An open source two way communication platform for the social sector

Elixir GenStage front-end for Redis Streams

Handy little queues and producers.

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

Elixir websockets library and utilities for Bitshares/Graphene 2.0 blockchain