@NoRepositoryBean public interface ReactiveCrudRepository<T,ID> extends Repository<T,ID>
Mono
,
Flux
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
count()
Returns the number of entities available.
|
reactor.core.publisher.Mono<Void> |
delete(T entity)
Deletes a given entity.
|
reactor.core.publisher.Mono<Void> |
deleteAll()
Deletes all entities managed by the repository.
|
reactor.core.publisher.Mono<Void> |
deleteAll(Iterable<? extends T> entities)
Deletes the given entities.
|
reactor.core.publisher.Mono<Void> |
deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)
Deletes the given entities supplied by a
Publisher . |
reactor.core.publisher.Mono<Void> |
deleteById(ID id)
Deletes the entity with the given id.
|
reactor.core.publisher.Mono<Void> |
deleteById(org.reactivestreams.Publisher<ID> id)
Deletes the entity with the given id supplied by a
Publisher . |
reactor.core.publisher.Mono<Boolean> |
existsById(ID id)
Returns whether an entity with the id exists.
|
reactor.core.publisher.Mono<Boolean> |
existsById(org.reactivestreams.Publisher<ID> id)
Returns whether an entity with the given id, supplied by a
Publisher , exists. |
reactor.core.publisher.Flux<T> |
findAll()
Returns all instances of the type.
|
reactor.core.publisher.Flux<T> |
findAllById(Iterable<ID> ids)
Returns all instances with the given IDs.
|
reactor.core.publisher.Flux<T> |
findAllById(org.reactivestreams.Publisher<ID> idStream)
Returns all instances of the type with the given IDs supplied by a
Publisher . |
reactor.core.publisher.Mono<T> |
findById(ID id)
Retrieves an entity by its id.
|
reactor.core.publisher.Mono<T> |
findById(org.reactivestreams.Publisher<ID> id)
Retrieves an entity by its id supplied by a
Publisher . |
<S extends T> |
save(S entity)
Saves a given entity.
|
<S extends T> |
saveAll(Iterable<S> entities)
Saves all given entities.
|
<S extends T> |
saveAll(org.reactivestreams.Publisher<S> entityStream)
Saves all given entities.
|
<S extends T> reactor.core.publisher.Mono<S> save(S entity)
entity
- must not be null.Mono
emitting the saved entity.IllegalArgumentException
- in case the given entity
is null.<S extends T> reactor.core.publisher.Flux<S> saveAll(Iterable<S> entities)
entities
- must not be null.Flux
emitting the saved entities.IllegalArgumentException
- in case the given Iterable
entities
is null.<S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream)
entityStream
- must not be null.Flux
emitting the saved entities.IllegalArgumentException
- in case the given Publisher
entityStream
is null.reactor.core.publisher.Mono<T> findById(ID id)
id
- must not be null.Mono
emitting the entity with the given id or Mono.empty()
if none found.IllegalArgumentException
- in case the given id
is null.reactor.core.publisher.Mono<T> findById(org.reactivestreams.Publisher<ID> id)
Publisher
.id
- must not be null. Uses the first emitted element to perform the find-query.Mono
emitting the entity with the given id or Mono.empty()
if none found.IllegalArgumentException
- in case the given Publisher
id
is null.reactor.core.publisher.Mono<Boolean> existsById(ID id)
id
- must not be null.Mono
emitting true if an entity with the given id exists, false otherwise.IllegalArgumentException
- in case the given id
is null.reactor.core.publisher.Mono<Boolean> existsById(org.reactivestreams.Publisher<ID> id)
Publisher
, exists. Uses the first emitted
element to perform the exists-query.id
- must not be null.Mono
emitting true if an entity with the given id exists, false otherwiseIllegalArgumentException
- in case the given Publisher
id
is null.reactor.core.publisher.Flux<T> findAll()
Flux
emitting all entities.reactor.core.publisher.Flux<T> findAllById(Iterable<ID> ids)
ids
- must not be null.Flux
emitting the found entities.IllegalArgumentException
- in case the given Iterable
ids
is null.reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<ID> idStream)
Publisher
.idStream
- must not be null.Flux
emitting the found entities.IllegalArgumentException
- in case the given Publisher
idStream
is null.reactor.core.publisher.Mono<Long> count()
Mono
emitting the number of entities.reactor.core.publisher.Mono<Void> deleteById(ID id)
id
- must not be null.Mono
signaling when operation has completed.IllegalArgumentException
- in case the given id
is null.reactor.core.publisher.Mono<Void> deleteById(org.reactivestreams.Publisher<ID> id)
Publisher
.id
- must not be null.Mono
signaling when operation has completed.IllegalArgumentException
- in case the given Publisher
id
is null.reactor.core.publisher.Mono<Void> delete(T entity)
entity
- must not be null.Mono
signaling when operation has completed.IllegalArgumentException
- in case the given entity is null.reactor.core.publisher.Mono<Void> deleteAll(Iterable<? extends T> entities)
entities
- must not be null.Mono
signaling when operation has completed.IllegalArgumentException
- in case the given Iterable
entities
is null.reactor.core.publisher.Mono<Void> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)
Publisher
.entityStream
- must not be null.Mono
signaling when operation has completed.IllegalArgumentException
- in case the given Publisher
entityStream
is null.reactor.core.publisher.Mono<Void> deleteAll()
Mono
signaling when operation has completed.Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.