From e20664457632f733bfcbc30667d92d964fc8f118 Mon Sep 17 00:00:00 2001
From: Luke Imhoff <luke.imhoff@dockyard.com>
Date: Wed, 30 May 2018 09:29:45 -0500
Subject: [PATCH] Don't pattern match on opaque :queue.queue

---
 apps/explorer/lib/explorer/buffered_task.ex | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/apps/explorer/lib/explorer/buffered_task.ex b/apps/explorer/lib/explorer/buffered_task.ex
index 60e098cba1..9db045f05d 100644
--- a/apps/explorer/lib/explorer/buffered_task.ex
+++ b/apps/explorer/lib/explorer/buffered_task.ex
@@ -152,7 +152,7 @@ defmodule Explorer.BufferedTask do
 
     state
     |> drop_task(ref)
-    |> queue(batch, retries + 1)
+    |> queue_in_state(batch, retries + 1)
   end
 
   defp buffer_entries(state, []), do: state
@@ -161,12 +161,12 @@ defmodule Explorer.BufferedTask do
     %{state | current_buffer: [entries | state.current_buffer]}
   end
 
-  defp queue(%{} = state, batch, retries) do
-    %{state | buffer: queue(state.buffer, batch, retries)}
+  defp queue_in_state(%{} = state, batch, retries) do
+    %{state | buffer: queue_in_queue(state.buffer, batch, retries)}
   end
 
-  defp queue({_, _} = que, batch, retries) do
-    :queue.in({batch, retries}, que)
+  defp queue_in_queue(queue, batch, retries) do
+    :queue.in({batch, retries}, queue)
   end
 
   defp do_initial_stream(%{init_chunk_size: init_chunk_size} = state) do
@@ -204,7 +204,7 @@ defmodule Explorer.BufferedTask do
     entries
     |> Enum.reverse()
     |> Enum.chunk_every(state.max_batch_size)
-    |> Enum.reduce(:queue.new(), fn batch, acc -> queue(acc, batch, 0) end)
+    |> Enum.reduce(:queue.new(), fn batch, acc -> queue_in_queue(acc, batch, 0) end)
   end
 
   defp take_batch(state) do
@@ -247,7 +247,7 @@ defmodule Explorer.BufferedTask do
     |> List.flatten()
     |> Enum.chunk_every(state.max_batch_size)
     |> Enum.reduce(%{state | current_buffer: []}, fn batch, state_acc ->
-      queue(state_acc, batch, 0)
+      queue_in_state(state_acc, batch, 0)
     end)
     |> flush()
   end