Elixir Flow Window and Trigger

flow_win_trigger.ex

defmodule Flowtest do
  @chunk 10
  def run( counts \\ 100, stages \\ 4 ) do
    window = Flow.Window.global
    |> Flow.Window.trigger_every(@chunk, :reset)  #トリガーの定義
    0..counts
    |> Flow.from_enumerable
    |> Flow.partition(window: window, stages: stages, hash: fn event -> {event, rem(div(event, @chunk), stages) } end )
    |> Flow.reduce(fn -> [] end, fn e, acc -> [e | acc] end)
    |> Flow.map_state(fn e -> Enum.reverse(e) end)
    |> Flow.emit(:state)
    |> Enum.to_list
    |> IO.inspect charlists: :as_lists
    :ok
  end
end