Packages

bquarp

0.5.3
0.6.0 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.1 0.3.0 0.2.0 0.1.0

A library for distributed reactive programming with flexible consistency guarantees drawing from QUARP and Rx.. Features the familiar behaviours and event streams in the spirit of FRP.

HexDocs

Current section

Files

Jump to
Readme
17 Versions
2 Dependencies
Dependants
Files
Activity
bquarp lib reactivity quality guarantee.ex
Raw

lib/reactivity/quality/guarantee.ex 

defmodule Reactivity.Quality.Guarantee do

  @moduledoc """

  Essential operations on guarantees.

  """



  @doc """

  Combines lists of consistency guarantees.

  """

  def combine(gss) do

    gss

    |> List.flatten()

    |> Enum.group_by(fn {g, _m} -> g end)

    |> Map.values()

    |> Enum.map(fn gs ->

      Enum.min_by(gs, fn {_g, m} -> m end)

    end)

    |> List.flatten()

  end

end