Packages

rivet

1.0.6
2.7.2 2.7.1 2.6.1 2.6.0 2.5.2 2.5.1 2.5.0 2.4.2 2.4.1 2.4.0 2.3.7 2.3.6 2.3.5 2.3.4 2.3.3 2.3.2 2.3.1 2.3.0 2.2.0 2.1.0 2.0.2 2.0.1 2.0.0 1.0.9 1.0.8 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.1 1.0.0

Elixir data model framework library

HexDocs

Current section

Files

Jump to
Readme
32 Versions
7 Dependencies
Dependants
Files
Activity
rivet lib rivet ecto collection stream.ex
Raw

lib/rivet/ecto/collection/stream.ex 

defmodule Rivet.Ecto.Collection.Stream do

  defmacro __using__(opts) do

    quote location: :keep, bind_quoted: [opts: opts] do

      def stream_all!(args, func) do

        stream = stream(args, [])



        @repo.transaction(fn ->

          stream

          |> Stream.each(func)

          |> Stream.run()

        end)

      end



      def stream(clauses, args)



      def stream(clauses, args) when is_list(clauses),

        do: from(t in @model, where: ^clauses) |> stream(args)



      def stream(query, args),

        do: Rivet.Ecto.Collection.enrich_query_args(query, args) |> @repo.stream()

    end

  end

end