Package org.hibernate.reactive.sql.results.spi

Class ReactiveListResultsConsumer<R>

java.lang.Object

org.hibernate.reactive.sql.results.spi.ReactiveListResultsConsumer<R>

All Implemented Interfaces:

ReactiveResultsConsumer<List<R>,R>

public class ReactiveListResultsConsumer<R>
extends Object
implements ReactiveResultsConsumer<List<R>,R>

See Also:

• ListResultsConsumer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ReactiveListResultsConsumer.UniqueSemantic	Ways this consumer can handle in-memory row de-duplication

Constructor Summary

Constructors

Constructor	Description
ReactiveListResultsConsumer(ReactiveListResultsConsumer.UniqueSemantic uniqueSemantic)

Method Summary

Modifier and Type	Method	Description
boolean	canResultsBeCached()
CompletionStage<List<R>>	consume(ReactiveValuesResultSet jdbcValues, SharedSessionContractImplementor session, JdbcValuesSourceProcessingOptions processingOptions, JdbcValuesSourceProcessingStateStandardImpl jdbcValuesSourceProcessingState, ReactiveRowProcessingState rowProcessingState, ReactiveRowReader<R> rowReader)
static <R> ReactiveListResultsConsumer<R>	instance(ReactiveListResultsConsumer.UniqueSemantic uniqueSemantic)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveListResultsConsumer

public ReactiveListResultsConsumer(ReactiveListResultsConsumer.UniqueSemantic uniqueSemantic)

Method Details

consume

public CompletionStage<List<R>> consume(ReactiveValuesResultSet jdbcValues,
 SharedSessionContractImplementor session,
 JdbcValuesSourceProcessingOptions processingOptions,
 JdbcValuesSourceProcessingStateStandardImpl jdbcValuesSourceProcessingState,
 ReactiveRowProcessingState rowProcessingState,
 ReactiveRowReader<R> rowReader)

Specified by:

consume in interface ReactiveResultsConsumer<List<R>,R>

instance

public static <R> ReactiveListResultsConsumer<R> instance(ReactiveListResultsConsumer.UniqueSemantic uniqueSemantic)

canResultsBeCached

public boolean canResultsBeCached()

Specified by:

canResultsBeCached in interface ReactiveResultsConsumer<List<R>,R>

toString

public String toString()

Overrides:

toString in class Object