From e15d5b599b7c163e20ffabde008e041987d582b8 Mon Sep 17 00:00:00 2001 From: Jin-Ho King Date: Sun, 31 May 2020 15:48:59 -0400 Subject: [PATCH] update producer.ex to remove compilation error warning: Stream.chunk/4 is deprecated. Use Stream.chunk_every/4 instead lib/parallel_stream/producer.ex:16: ParallelStream.Producer.build!/4 --- lib/parallel_stream/producer.ex | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/parallel_stream/producer.ex b/lib/parallel_stream/producer.ex index 3e749f9..066756f 100644 --- 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 -> {