Make media encrypter stream ordered
Co-authored-by: Chris Eager <79161849+eager-signal@users.noreply.github.com>
This commit is contained in:
parent
3a1ecb342f
commit
498dcbbfe8
|
@ -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);
|
||||
|
|
Loading…
Reference in New Issue