Package org.springframework.data.couchbase.repository.query

Class ReactiveCouchbaseParameterAccessor

java.lang.Object

org.springframework.data.repository.query.ParametersParameterAccessor

org.springframework.data.couchbase.repository.query.ReactiveCouchbaseParameterAccessor

All Implemented Interfaces:

Iterable<Object>, ParameterAccessor

public class ReactiveCouchbaseParameterAccessor
extends ParametersParameterAccessor

Reactive ParametersParameterAccessor implementation that subscribes to reactive parameter wrapper types upon creation. This class performs synchronization when accessing parameters.

Since:

3.0

Author:

Subhashni Balakrishnan, Mark Paluch

Constructor Summary

Constructors

Constructor	Description
ReactiveCouchbaseParameterAccessor(CouchbaseQueryMethod method, Object[] values)

Method Summary

Modifier and Type	Method	Description
Object	getBindableValue(int index)
Object[]	getValues()
reactor.core.publisher.Mono<ReactiveCouchbaseParameterAccessor>	resolveParameters()	Resolve parameters that were provided through reactive wrapper types.

Methods inherited from class org.springframework.data.repository.query.ParametersParameterAccessor

findDynamicProjection, getPageable, getParameters, getSort, getValue, hasBindableNullValue, iterator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

ReactiveCouchbaseParameterAccessor

public ReactiveCouchbaseParameterAccessor(CouchbaseQueryMethod method,
 Object[] values)

Method Details

getValues

public Object[] getValues()

Overrides:

getValues in class ParametersParameterAccessor

getBindableValue

public Object getBindableValue(int index)

Specified by:

getBindableValue in interface ParameterAccessor

Overrides:

getBindableValue in class ParametersParameterAccessor

resolveParameters

public reactor.core.publisher.Mono<ReactiveCouchbaseParameterAccessor> resolveParameters()

Resolve parameters that were provided through reactive wrapper types. Flux is collected into a list, values from Mono's are used directly.

Returns: