reducer pipeline snippets

example_pipeline.ex

  user_token
    |> find_user_by_token
    |> fetch("/messages/unread")
    |> parse_json_to_message_list
    |> Enum.each(&save_message(&1))
    
    
    Enum.each(
      parse_json_to_message_list(
        fetch(find_user_by_token(user_token), "/messages/unread")
    ), &save_message(&1))

fluent.rb

points
  .map { |point| flood_fill(point, continent_id) }
  .compact
  .reduce([], &:+)
  .uniq