Packages

gen_stage

0.6.0
1.3.2 1.3.1 1.3.0 1.2.1 1.2.0 1.1.2 1.1.1 1.1.0 1.0.0 0.14.3 0.14.2 0.14.1 0.14.0 0.13.1 0.13.0 0.12.2 0.12.1 0.12.0 retired 0.11.0 0.10.0 0.9.0 0.8.0 0.7.0 0.6.1 0.6.0 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.0 0.2.1 0.2.0 0.2.0-dev 0.1.0

Producer and consumer actors with back-pressure for Elixir

HexDocs

Current section

Files

Jump to
Readme
35 Versions
0 Dependencies
Dependants
Files
Activity
gen_stage CHANGELOG.md
Raw

CHANGELOG.md 

# Changelog



## v0.6.0 (2016-10-04)



### Enhancements



  * Introduce `Flow.departition/5`

  * Include examples of broadcasters and rate limiters in the documentation

  * Allow custom named, non-integer, partitions



### Bug fixes



  * Ensure dynamic supervisor respects `min_demand` and does not send demand to soon



### Backwards incompatible changes



  * Remove `Flow.new/0`, `Flow.new/1` and `Flow.new/2` in favor of passing options to `from_enumerable/2` and `from_stage/2`

  * Remove `Flow.partition/3` and `Flow.merge/3` in favor of passing the `:window` option to `Flow.partition/2` and `Flow.merge/2`



## v0.5.0 (2016-08-09)



This release moves `Flow` from under the `GenStage` namespace and into `Experimental.Flow`.



### Enhancements



  * Add `Flow.uniq/2` and `Flow.uniq_by/2`

  * Add `Flow.start_link/2` and `Flow.into_stages/3`

  * Add `Flow.window_join/8`

  * Unify window and partition APIs

  * Support `Flow.Window.global/0` and `Flow.Window.fixed/3`



## v0.4.3 (2016-07-28)



### Enhancements



  * Add `Flow.inner_join/6`

  * Add `GenStage.demand/2` that allows a producer to accumulate demand as a synchronization mechanism

  * Improve performance for the partition dispatcher and allow it to change the partitioned event



## v0.4.2 (2016-07-25)



### Bug fixes



  * Fix a bug where a flow wouldn't terminate if a source stream halts



## v0.4.1 (2016-07-21)



### Enhancements



  * Add `Flow.trigger/3` and `Flow.trigger_every/4` supporting custom, count and processing-time triggers. Event-time triggers can be implemented via `trigger/3`. Event-time triggers will be added once windows support is included



## v0.4.0 (2016-07-19)



### Enhancements



  * Introduce `Flow` with enumerable/stream based operations

  * Include more information on `:sys.get_status/1` calls for GenStage



### Bug fixes



  * Fix a bug where a `:producer_consumer` stage which filtered events would eventually halt

  * Fix `format_status/2` results when inspecting GenStage in `:observer`



## v0.3.0 (2016-07-12)



### Enhancements



  * Support notifications

  * Introduce `GenStage.stream/1` to stream events as a consumer from a stage

  * Introduce `GenStage.from_enumerable/2` to start a producer stage that emits events from an enumerable (or a stream)



## v0.2.1 (2016-07-08)



### Enhancements



  * Add `GenStage.PartitionDispatcher`

  * Set default `:max_demand` to 1000

  * Use buffer based `:producer_consumer` to avoid escalating demand



## v0.2.0 (2016-07-05)



### Enhancements



  * Support `:producer_consumer` type

  * Support `:infinity` as `:buffer_size` (useful for `:producer_consumer`)



### Backwards incompatible changes



  * Namespace all modules under `Experimental`

  * Ensure `:cancel` reason does not cascade through the pipeline



## v0.1.0 (2016-07-03)



### Enhancements



  * Include GenStage with `:producer` and `:consumer` types

  * Include DynamicSupervisor implemented as a `GenStage` consumer and that provides the `:simple_one_for_one` functionality