Package io.micronaut.data.repository.reactive

Interface ReactorPageableRepository<E,ID>

Type Parameters:

E - The entity type

ID - The ID type

All Superinterfaces:

GenericRepository<E,ID>, ReactiveStreamsCrudRepository<E,ID>, ReactiveStreamsPageableRepository<E,ID>, ReactorCrudRepository<E,ID>

public interface ReactorPageableRepository<E,ID>
extends ReactorCrudRepository<E,ID>, ReactiveStreamsPageableRepository<E,ID>

A repository that supports pagination.

Since:

3.4.0

Author:

Denis Stepanov

Method Summary

Modifier and Type	Method	Description
@NonNull reactor.core.publisher.Mono<Page<E>>	findAll(@NonNull Pageable pageable)	Finds all records for the given pageable.
@NonNull reactor.core.publisher.Flux<E>	findAll(@NonNull Sort sort)	Find all results for the given sort order.

Methods inherited from interface io.micronaut.data.repository.reactive.ReactorCrudRepository

count, delete, deleteAll, deleteAll, deleteById, existsById, findAll, findById, save, saveAll, update, updateAll

Method Details

findAll

@NonNull
@NonNull reactor.core.publisher.Flux<E> findAll(@NonNull
 @NonNull Sort sort)

Description copied from interface: ReactiveStreamsPageableRepository

Find all results for the given sort order.

Specified by:

findAll in interface ReactiveStreamsPageableRepository<E,ID>

Parameters:

sort - The sort

Returns:

The results publisher

findAll

@NonNull
@NonNull reactor.core.publisher.Mono<Page<E>> findAll(@NonNull
 @NonNull Pageable pageable)

Description copied from interface: ReactiveStreamsPageableRepository

Finds all records for the given pageable.

Specified by:

findAll in interface ReactiveStreamsPageableRepository<E,ID>

Parameters:

pageable - The pageable.

Returns:

The results publisher