josevalim

josevalim

Creator of Elixir

Hello everyone,

We have just released GenStage 0.10.0 with an important bug fix if you were using the BroadcastDispatcher with a selector. It also has an improvements to Flow, both in terms of API and internals.

The CHANGELOG is shown below:

Enhancements

  • Add Flow.group_by/3 and Flow.group_by_key/3 as conveniences around Flow.reduce/3
  • Add Flow.map_values/2 for mapping over the values in a key-value based state
  • Add Flow.take_sort/3 that efficiently sorts and takes the top N entries

Bug fixes

  • Ensure BroadcastDispatcher sends demand to itself when custom selector discards events
  • Ensure flows started with Flow.start_link/2 properly terminate if producers terminate
  • Ensure flows exit locally instead of relying on linked processes exits. With this change, Flow.run(flow) and Enum.to_list(flow) no longer start stages linked directly to the caller but does so through a supervisor

Showing Posts 1 to 1

formido

formido

Speaking of GenStage:

— All posts loaded —

Where Next? Top

Trending in News Top

Other Trending Topics Top

mudasobwa
I am happy to introduce the very α version of the new programming language compiled to BEAM. Welcome Cure. It has literally three kille...
New
garrison
Hobbes is a low-level distributed database for the Elixir programming language. Hobbes provides a simple, safe, and scalable storage lay...
New
marciok
Hi there! We created Gust: A task orchestrator inspired by Airflow. For those who have never heard about Aiflow, it’s a Python-based wor...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
Dmk
Xamal is a deployment tool for Elixir apps that deploys native releases to bare metal servers over SSH. It’s a port of GitHub - basecamp/...
New
Damirados
Hello everyone. After busy few months I am happy to announce v0.1.0 of Emerge & Solve. They are GUI (Emerge) and State management (S...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews