chore: replace deprecated func to fix warning

beatrichartz · Jun 5, 2020 · 5d7879b · 5d7879b
1 parent 75788a6
commit 5d7879b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/parallel_stream/producer.ex b/lib/parallel_stream/producer.ex
@@ -13,7 +13,7 @@ defmodule ParallelStream.Producer do
     chunk_size = worker_count * worker_work_ratio
 
     stream
-    |> Stream.chunk(chunk_size, chunk_size, [])
+    |> Stream.chunk_every(chunk_size, chunk_size, [])
     |> Stream.transform(
       fn ->
         {