Packages

ferricstore

0.11.1
0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.8.0 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.2.0 0.1.0

FerricFlow durable workflows and queues with native-protocol storage, Raft durability, and Bitcask persistence.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
10 Dependencies
Dependants
Files
Activity
ferricstore lib ferricstore batch_result.ex
Raw

lib/ferricstore/batch_result.ex 

defmodule Ferricstore.BatchResult do

  @moduledoc false



  @type mismatch_reason ::

          {:batch_result_mismatch, non_neg_integer(), non_neg_integer()}

          | {:invalid_batch_results, term()}



  @spec map_exact(list(), term(), (term(), term() -> term())) ::

          {:ok, list()} | {:error, mismatch_reason()}

  def map_exact(expected, results, mapper)

      when is_list(expected) and is_list(results) and is_function(mapper, 2) do

    case matching_counts(expected, results, 0) do

      :ok -> {:ok, Enum.zip_with(expected, results, mapper)}

      {:error, _reason} = error -> error

    end

  end



  def map_exact(expected, results, mapper)

      when is_list(expected) and is_function(mapper, 2) do

    {:error, {:invalid_batch_results, results}}

  end



  defp matching_counts([], [], _seen), do: :ok



  defp matching_counts([], results, seen),

    do: {:error, {:batch_result_mismatch, seen, seen + length(results)}}



  defp matching_counts(expected, [], seen),

    do: {:error, {:batch_result_mismatch, seen + length(expected), seen}}



  defp matching_counts([_expected | expected_rest], [_result | result_rest], seen),

    do: matching_counts(expected_rest, result_rest, seen + 1)

end