diff --git a/lib/cereal/builders/base.ex b/lib/cereal/builders/base.ex index 4c9f48e..0efba32 100644 --- a/lib/cereal/builders/base.ex +++ b/lib/cereal/builders/base.ex @@ -8,7 +8,7 @@ defmodule Cereal.Builders.Base do @doc """ Builds a Cereal Base struct that encapsulates the JSON that will be serialized. - Will correctly handle Scrievener pagination. + Will correctly handle Scrivener pagination. """ @spec build(Cereal.Context.t()) :: __MODULE__.t() def build(context) diff --git a/lib/cereal/builders/entity.ex b/lib/cereal/builders/entity.ex index 87b9bd7..7e377fc 100644 --- a/lib/cereal/builders/entity.ex +++ b/lib/cereal/builders/entity.ex @@ -5,12 +5,11 @@ defmodule Cereal.Builders.Entity do def build(%{data: data} = context) when is_list(data) do data - |> Task.async_stream(fn entity -> + |> Enum.map(fn entity -> context |> Map.put(:data, entity) |> build() end) - |> Enum.map(fn {:ok, result} -> result end) end def build(%{serializer: serializer} = context) do diff --git a/lib/cereal/formatters/attributes.ex b/lib/cereal/formatters/attributes.ex index 0c21c6c..11c8932 100644 --- a/lib/cereal/formatters/attributes.ex +++ b/lib/cereal/formatters/attributes.ex @@ -3,11 +3,7 @@ defmodule Cereal.Formatters.Attributes do def format(%Cereal.Builders.Base{data: data}), do: format_data(data) - defp format_data(data) when is_list(data) do - data - |> Task.async_stream(&format_data(&1)) - |> Enum.map(fn {:ok, result} -> result end) - end + defp format_data(data) when is_list(data), do: data |> Enum.map(&format_data/1) defp format_data(%Cereal.Builders.Entity{} = entity) do entity.attributes