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()
Mono<ReactiveCouchbaseParameterAccessor>	resolveParameters()	Resolve parameters that were provided through reactive wrapper types.

Methods inherited from class ParametersParameterAccessor

findDynamicProjection, getLimit, getPageable, getParameters, getScore, getScoreRange, getScrollPosition, getSort, getValue, getVector, hasBindableNullValue, iterator

Methods inherited from class Object

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

Methods inherited from interface 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 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: