diff options
author | Christian Schneppe <christian@pix-art.de> | 2018-04-12 20:56:39 +0200 |
---|---|---|
committer | Christian Schneppe <christian@pix-art.de> | 2018-04-12 20:56:39 +0200 |
commit | bdc3e725d1610d14374dc7983a612673d980e979 (patch) | |
tree | b1fb509d17d7ddc8438c92a437fc02510e7696bd /src/main/java/de/pixart/messenger/xmpp/XmppConnection.java | |
parent | 681511379f85b3b01cf548bfb7493c8283e2072d (diff) |
presist http upload availibility
Diffstat (limited to '')
-rw-r--r-- | src/main/java/de/pixart/messenger/xmpp/XmppConnection.java | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java b/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java index 515f0b3c6..03005b6e3 100644 --- a/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java +++ b/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java @@ -37,6 +37,7 @@ import java.util.Iterator; import java.util.List; import java.util.Map.Entry; import java.util.Random; +import java.util.Set; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; @@ -143,8 +144,8 @@ public class XmppConnection implements Runnable { private final HashMap<Jid, ServiceDiscoveryResult> disco = new HashMap<>(); private final SparseArray<AbstractAcknowledgeableStanza> mStanzaQueue = new SparseArray<>(); private final Hashtable<String, Pair<IqPacket, OnIqPacketReceived>> packetCallbacks = new Hashtable<>(); - private final ArrayList<OnAdvancedStreamFeaturesLoaded> advancedStreamFeaturesLoadedListeners = new ArrayList<>(); - private final XmppConnectionService mXmppConnectionService; + private final Set<OnAdvancedStreamFeaturesLoaded> advancedStreamFeaturesLoadedListeners = new HashSet<>(); + private final XmppConnectionService mXmppConnectionService; private Socket socket; private XmlReader tagReader; private TagWriter tagWriter = new TagWriter(); @@ -1462,9 +1463,7 @@ public class XmppConnection implements Runnable { } public void addOnAdvancedStreamFeaturesAvailableListener(final OnAdvancedStreamFeaturesLoaded listener) { - if (!this.advancedStreamFeaturesLoadedListeners.contains(listener)) { - this.advancedStreamFeaturesLoadedListeners.add(listener); - } + this.advancedStreamFeaturesLoadedListeners.add(listener); } private void forceCloseSocket() { |