iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor multipart upload

Browse Source
This commit is contained in:
pivovarit 2017-05-05 17:50:36 +02:00
parent 744799630f
commit 1a54133472
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
spring-5/src/main/java/com/baeldung/functional/FormHandler.java
View File

@ -1,10 +1,12 @@
package com.baeldung.functional; package com.baeldung.functional;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.util.MultiValueMap; import org.springframework.util.MultiValueMap;
import org.springframework.web.reactive.function.server.ServerRequest; import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse; import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import java.util.List;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import static org.springframework.web.reactive.function.BodyExtractors.toDataBuffers; import static org.springframework.web.reactive.function.BodyExtractors.toDataBuffers;
@ -28,13 +30,15 @@ public class FormHandler {
return request return request
.body(toDataBuffers()) .body(toDataBuffers())
.collectList() .collectList()
.flatMap(dataBuffers -> { .flatMap(dataBuffers -> ok()
AtomicLong atomicLong = new AtomicLong(0); .body(fromObject(extractData(dataBuffers).toString())));
dataBuffers.forEach(d -> atomicLong.addAndGet(d }
.asByteBuffer()
.array().length));
return ok().body(fromObject(atomicLong.toString())); private AtomicLong extractData(List<DataBuffer> dataBuffers) {
}); AtomicLong atomicLong = new AtomicLong(0);
dataBuffers.forEach(d -> atomicLong.addAndGet(d
.asByteBuffer()
.array().length));
return atomicLong;
} }
} }