keep prev data only when delta negotiated

centrifugal · Oct 9, 2024 · bda868e · bda868e
1 parent 9ad97af
commit bda868e
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Subscription.java b/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Subscription.java
@@ -179,11 +179,13 @@ void handlePublication(Protocol.Publication pub) throws Exception {
         ClientInfo info = ClientInfo.fromProtocolClientInfo(pub.getInfo());
         PublicationEvent event = new PublicationEvent();
         byte[] pubData = pub.getData().toByteArray();
-        byte[] prevData = this.getPrevData();
-        if (prevData != null && pub.getDelta()) {
-            pubData = Fossil.applyDelta(prevData, pubData);
+        if (this.deltaNegotiated) {
+            byte[] prevData = this.getPrevData();
+            if (prevData != null && pub.getDelta()) {
+                pubData = Fossil.applyDelta(prevData, pubData);
+            }
+            this.setPrevData(pubData);
         }
-        this.setPrevData(pubData);
         event.setData(pubData);
         event.setInfo(info);
         event.setOffset(pub.getOffset());