Replaced for loops with while loops and iterators.

Author: lmorda

lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java

@@ -6,6 +6,7 @@
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -170,21 +171,22 @@ public Observable<StompMessage> topic(String destinationPath, List<StompHeader>
            subscribersSet.add(subscriber);
 
        }).doOnUnsubscribe(() -> {
-           Set<String> destSet = new HashSet<String>();
-           for (String dest : mSubscribers.keySet()) {
-               Set<Subscriber<? super StompMessage>> set = mSubscribers.get(dest);
-               for (Subscriber<? super StompMessage> subscriber : set) {
+           Iterator<String> mapIterator = mSubscribers.keySet().iterator();
+           while (mapIterator.hasNext()) {
+               String destinationUrl = mapIterator.next();
+               Set<Subscriber<? super StompMessage>> set = mSubscribers.get(destinationUrl);
+               Iterator<Subscriber<? super StompMessage>> setIterator = set.iterator();
+               while (setIterator.hasNext()) {
+                   Subscriber<? super StompMessage> subscriber = setIterator.next();
                    if (subscriber.isUnsubscribed()) {
-                       set.remove(subscriber);
+                       setIterator.remove();
                        if (set.size() < 1) {
-                           destSet.add(dest);
-                           unsubscribePath(dest).subscribe();
+                           mapIterator.remove();
+                           unsubscribePath(destinationUrl).subscribe();
                        }
                    }
                }
            }
-           for (String dest : destSet)
-               mSubscribers.remove(dest);
        });
    }