Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing

Browse Source
This commit is contained in:
Juergen Hoeller
2018-06-29 22:36:08 +02:00
parent e22466e9d5
commit 641039d85d
2 changed files with 40 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-webmvc/src/main/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandler.java
View File

@@ -319,7 +319,6 @@ class ReactiveTypeHandler {
this.subscription.cancel();
}
}
}
@@ -402,16 +401,12 @@ class ReactiveTypeHandler {
private final CollectedValuesList values;
DeferredResultSubscriber(DeferredResult<Object> result, ReactiveAdapter adapter,
ResolvableType elementType) {
DeferredResultSubscriber(DeferredResult<Object> result, ReactiveAdapter adapter, ResolvableType elementType) {
this.result = result;
this.multiValueSource = adapter.isMultiValue();
this.values = new CollectedValuesList(elementType);
}
public void connect(ReactiveAdapter adapter, Object returnValue) {
Publisher<Object> publisher = adapter.toPublisher(returnValue);
publisher.subscribe(this);
@@ -447,6 +442,7 @@ class ReactiveTypeHandler {
}
}
/**
* List of collect values where all elements are a specified type.
*/