diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/backup/BackupMediaEncrypter.java b/service/src/main/java/org/whispersystems/textsecuregcm/backup/BackupMediaEncrypter.java
index 38e46d671..a40403213 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/backup/BackupMediaEncrypter.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/backup/BackupMediaEncrypter.java
@@ -46,7 +46,7 @@ public class BackupMediaEncrypter {
           return ByteBuffer.wrap(cipher.getIV());
         }),
         Flux.from(FlowAdapters.toPublisher(sourceBody))
-            .flatMap(buffers -> Flux.fromIterable(buffers))
+            .concatMap(Flux::fromIterable)
             .concatMap(byteBuffer -> {
               final byte[] copy = new byte[byteBuffer.remaining()];
               byteBuffer.get(copy);