🗄️

Marcos Benatti Lauer mbenatti

🗄️

mbenatti / ecto_batch_stream.ex

Created January 24, 2020 18:10 — forked from maxim/ecto_batch_stream.ex

Similar to Rails `find_each`, but for Elixir's Ecto, using Stream

	defmodule EctoBatchStream do
	import Ecto.Query, only: [from: 1, from: 2]

	@batch_size 1000

	# Example:
	#
	# query = from u in MyApp.User, select: u.email
	# stream = EctoBatchStream.stream(MyApp.Repo, query)
	# stream \|> Stream.take(3) \|> Enum.to_list # => […]