Simplify use of Reactor's cast operator
This commit replaces filter(x -> x instanceof C).cast(C.class) with the built-in ofType(C.class). See gh-32141
This commit is contained in:
parent
ad7c090f4c
commit
d96a63944c
|
@ -168,8 +168,7 @@ public class PartEventHttpMessageReader extends LoggingCodecSupport implements H
|
|||
|
||||
HttpHeaders headers = headersToken.headers();
|
||||
Flux<MultipartParser.BodyToken> bodyTokens =
|
||||
flux.filter(t -> t instanceof MultipartParser.BodyToken)
|
||||
.cast(MultipartParser.BodyToken.class);
|
||||
flux.ofType(MultipartParser.BodyToken.class);
|
||||
return createEvents(headers, bodyTokens);
|
||||
}
|
||||
else {
|
||||
|
|
|
@ -240,9 +240,8 @@ class MultipartRouterFunctionIntegrationTests extends AbstractRouterFunctionInte
|
|||
|
||||
public Mono<ServerResponse> transferTo(ServerRequest request) {
|
||||
return request.body(BodyExtractors.toParts())
|
||||
.filter(FilePart.class::isInstance)
|
||||
.ofType(FilePart.class)
|
||||
.next()
|
||||
.cast(FilePart.class)
|
||||
.flatMap(part -> createTempFile()
|
||||
.flatMap(tempFile ->
|
||||
part.transferTo(tempFile)
|
||||
|
|
Loading…
Reference in New Issue