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

DATACOUCH-311 - Upgrade to Reactor 3.1 M2.

Browse Source 
Adopt to API change from Publisher.subscribe() to Publisher.toProcessor().
This commit is contained in:
Mark Paluch
2017-06-01 10:01:39 +02:00
parent 6bcf44f0bf
commit 9758ad9802
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/springframework/data/couchbase/repository/query/ReactiveCouchbaseParameterAccessor.java
View File

@@ -31,16 +31,15 @@ import reactor.core.publisher.MonoProcessor;
* to reactive parameter wrapper types upon creation. This class performs synchronization when accessing parameters.
*
* @author Subhashni Balakrishnan
* @author Mark Paluch
* @since 3.0
*/
public class ReactiveCouchbaseParameterAccessor extends ParametersParameterAccessor {
private final Object[] values;
private final List<MonoProcessor<?>> subscriptions;
public ReactiveCouchbaseParameterAccessor(CouchbaseQueryMethod method, Object[] values) {
super(method.getParameters(), values);
this.values = values;
this.subscriptions = new ArrayList<>(values.length);
for (int i = 0; i < values.length; i++) {
@@ -53,9 +52,9 @@ public class ReactiveCouchbaseParameterAccessor extends ParametersParameterAcces
}
if (ReactiveWrappers.isSingleValueType(value.getClass())) {
subscriptions.add(ReactiveWrapperConverters.toWrapper(value, Mono.class).subscribe());
subscriptions.add(ReactiveWrapperConverters.toWrapper(value, Mono.class).toProcessor());
} else {
subscriptions.add(ReactiveWrapperConverters.toWrapper(value, Flux.class).collectList().subscribe());
subscriptions.add(ReactiveWrapperConverters.toWrapper(value, Flux.class).collectList().toProcessor());
}
}
}