Package io.micronaut.data.repository.reactive

Interface ReactorCrudRepository<E,ID>

Type Parameters:
E - The entity type
ID - The ID type
All Superinterfaces:
GenericRepository<E,ID>, ReactiveStreamsCrudRepository<E,ID>
All Known Subinterfaces:
BookReactiveRepository, PersonReactiveRepository, ReactorPageableRepository<E,ID>
public interface ReactorCrudRepository<E,ID> extends ReactiveStreamsCrudRepository<E,ID>
CRUD repository for Project Reactor.
Since:
3.1
Author:
graemerocher, Denis Stepanov
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<Long>
    count()
    Returns the number of entities available.
    reactor.core.publisher.Mono<Long>
    delete(E entity)
    Deletes a given entity.
    reactor.core.publisher.Mono<Long>
    deleteAll()
    Deletes all entities managed by the repository.
    reactor.core.publisher.Mono<Long>
    deleteAll(Iterable<? extends E> entities)
    Deletes the given entities.
    reactor.core.publisher.Mono<Long>
    deleteById(ID id)
    Deletes the entity with the given id.
    reactor.core.publisher.Mono<Boolean>
    existsById(ID id)
    Returns whether an entity with the given id exists.
    reactor.core.publisher.Flux<E>
    findAll()
    Returns all instances of the type.
    reactor.core.publisher.Mono<E>
    findById(ID id)
    Retrieves an entity by its id.
    <S extends E>
    reactor.core.publisher.Mono<S>
    save(S entity)
    Saves the given valid entity, returning a possibly new entity representing the saved state.
    <S extends E>
    reactor.core.publisher.Flux<S>
    saveAll(Iterable<S> entities)
    Saves all given entities, possibly returning new instances representing the saved state.
    <S extends E>
    reactor.core.publisher.Mono<S>
    update(S entity)
    This method issues an explicit update for the given entity.
    <S extends E>
    reactor.core.publisher.Flux<S>
    updateAll(Iterable<S> entities)
    This method issues an explicit update for the given entities.