Extra v0.2.0 Flow.Extra
Extensions to the Flow module provided by gen_stage.
Link to this section Summary
Functions
Streams tuples in the form of {:ok, any} or {:error, any} and
filtering errors and unwrapping the :ok tuples
Link to this section Functions
Streams tuples in the form of {:ok, any} or {:error, any} and
filtering errors and unwrapping the :ok tuples.
iex> Flow.from_enumerable([{:ok, 1}, {:error, "Fail"}])
...> |> Flow.Extra.unwrap_oks
...> |> Enum.into([])
[1]