35f29f42e3
- flake.nix: Elixir 1.18.4 / OTP 27 / Node 22 dev shell - .envrc: use flake - config/config.exs: move fetch_env! to runtime.exs (compile-time safe) - config/runtime.exs: all secrets loaded at runtime via env vars - mix.lock: generated after mix deps.get - All 3 apps compile cleanly Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
43 lines
1 KiB
Elixir
43 lines
1 KiB
Elixir
defmodule Ecto.Adapters.SQL.Stream do
|
|
@moduledoc false
|
|
|
|
defstruct [:meta, :statement, :params, :opts]
|
|
|
|
def build(meta, statement, params, opts) do
|
|
%__MODULE__{meta: meta, statement: statement, params: params, opts: opts}
|
|
end
|
|
end
|
|
|
|
alias Ecto.Adapters.SQL.Stream
|
|
|
|
defimpl Enumerable, for: Stream do
|
|
def count(_), do: {:error, __MODULE__}
|
|
|
|
def member?(_, _), do: {:error, __MODULE__}
|
|
|
|
def slice(_), do: {:error, __MODULE__}
|
|
|
|
def reduce(stream, acc, fun) do
|
|
%Stream{meta: meta, statement: statement, params: params, opts: opts} = stream
|
|
Ecto.Adapters.SQL.reduce(meta, statement, params, opts, acc, fun)
|
|
end
|
|
end
|
|
|
|
defimpl Collectable, for: Stream do
|
|
def into(stream) do
|
|
%Stream{meta: meta, statement: statement, params: params, opts: opts} = stream
|
|
{state, fun} = Ecto.Adapters.SQL.into(meta, statement, params, opts)
|
|
{state, make_into(fun, stream)}
|
|
end
|
|
|
|
defp make_into(fun, stream) do
|
|
fn
|
|
state, :done ->
|
|
fun.(state, :done)
|
|
stream
|
|
|
|
state, acc ->
|
|
fun.(state, acc)
|
|
end
|
|
end
|
|
end
|