Only send bundle if necessary

bisq-network · Jul 10, 2019 · 31a4ba3 · 31a4ba3
1 parent b44cb45
commit 31a4ba3
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/p2p/src/main/java/bisq/network/p2p/network/Connection.java b/p2p/src/main/java/bisq/network/p2p/network/Connection.java
@@ -301,7 +301,11 @@ public void sendMessage(NetworkEnvelope networkEnvelope) {
                                     bundleSender.schedule(() -> {
                                         if (!stopped) {
                                             synchronized (lock) {
-                                                protoOutputStream.writeEnvelope(queueOfBundles.poll());
+                                                BundleOfEnvelopes current = queueOfBundles.poll();
+                                                if(current.getEnvelopes().size() == 1)
+                                                    protoOutputStream.writeEnvelope(current.getEnvelopes().get(0));
+                                                else
+                                                    protoOutputStream.writeEnvelope(current);
                                             }
                                         }
                                     }, lastSendTimeStamp - now, TimeUnit.MILLISECONDS);