From 74d59673a8173c051808ba0e24fcc83fc2ce0e23 Mon Sep 17 00:00:00 2001
From: Paul Fake <pauljunkaccount@gmail.com>
Date: Wed, 21 Nov 2018 21:38:06 -0500
Subject: [PATCH] Delegate for comparisons

---
 Source/MQTTnet/Internal/BlockingQueue.cs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/Source/MQTTnet/Internal/BlockingQueue.cs b/Source/MQTTnet/Internal/BlockingQueue.cs
index 546b6461..2812349a 100644
--- a/Source/MQTTnet/Internal/BlockingQueue.cs
+++ b/Source/MQTTnet/Internal/BlockingQueue.cs
@@ -77,11 +77,11 @@ namespace MQTTnet.Internal
             }
         }
 
-        public void RemoveFirstIfEqual(TItem item)
+        public void RemoveFirstIfEqual(TItem item, Func<TItem, TItem, bool> areEqual)
         {
             lock (_syncRoot)
             {
-                if (_items.Count > 0 && EqualityComparer<TItem>.Default.Equals(_items.First.Value, item))
+                if (_items.Count > 0 && areEqual(_items.First.Value, item))
                 {
                     _items.RemoveFirst();
                 }