Iterator.empty patch

src/lavinmq/exchange.cr

@@ -1,11 +1 @@
 require "./exchange/*"
-
-module LavinMQ
-  struct EmptyIterator(T)
-    include Iterator(T)
-
-    def next
-      stop
-    end
-  end
-end

src/lavinmq/exchange/consistent_hash.cr

@@ -50,7 +50,7 @@ module LavinMQ
       if d = @hasher.get(key)
         {d}.each
       else
-        EmptyIterator(Destination).new
+        Iterator(Destination).empty
       end
     end
 

src/lavinmq/exchange/default.cr

@@ -7,18 +7,18 @@ module LavinMQ
     end
 
     def bindings_details : Iterator(BindingDetails)
-      EmptyIterator(BindingDetails).new
+      Iterator(BindingDetails).empty
     end
 
     def bindings : Iterator(Destination)
-      EmptyIterator(Destination).new
+      Iterator(Destination).empty
     end
 
     protected def bindings(routing_key, headers) : Iterator(Destination)
       if q = @vhost.queues[routing_key]?
         Tuple(Destination).new(q).each
       else
-        EmptyIterator(Destination).new
+        Iterator(Destination).empty
       end
     end
 

src/lavinmq/exchange/topic.cr

@@ -53,7 +53,7 @@ module LavinMQ
     private def select_matches(routing_key) : Iterator(Destination)
       binding_keys = @bindings
 
-      return EmptyIterator(Destination).new if binding_keys.empty?
+      return Iterator(Destination).empty if binding_keys.empty?
 
       # optimize the case where the only binding key is '#'
       if binding_keys.size == 1