diff --git a/libsignal/service/src/main/java/org/whispersystems/signalservice/api/services/CdsiSocket.java b/libsignal/service/src/main/java/org/whispersystems/signalservice/api/services/CdsiSocket.java
index a9e4377819..eeac91dec4 100644
--- a/libsignal/service/src/main/java/org/whispersystems/signalservice/api/services/CdsiSocket.java
+++ b/libsignal/service/src/main/java/org/whispersystems/signalservice/api/services/CdsiSocket.java
@@ -162,7 +162,7 @@ final class CdsiSocket {
                   throw new CdsiResourceExhaustedException(dataResponse.getRetryAfterSecs());
                 }
 
-                emitter.onNext(ClientResponse.parseFrom(client.establishedRecv(bytes.toByteArray())));
+                emitter.onNext(dataResponse);
                 break;
 
               case CLOSED: