RxJava3CrudRepository (Spring Data Core 2.5.1 API)

All Superinterfaces:

Repository<T,ID>

All Known Subinterfaces:

RxJava3SortingRepository<T,ID>
```
@NoRepositoryBean
public interface RxJava3CrudRepository<T,ID>
extends Repository<T,ID>
```
Interface for generic CRUD operations on a repository for a specific type. This repository follows reactive paradigms and uses RxJava 3 types.

Since:

2.4

Author:

Mark Paluch

See Also:

Maybe, Single, Flowable, Completable

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`io.reactivex.rxjava3.core.Single<Long>`	`count()` Returns the number of entities available.
`io.reactivex.rxjava3.core.Completable`	`delete(T entity)` Deletes a given entity.
`io.reactivex.rxjava3.core.Completable`	`deleteAll()` Deletes all entities managed by the repository.
`io.reactivex.rxjava3.core.Completable`	`deleteAll(io.reactivex.rxjava3.core.Flowable<? extends T> entityStream)` Deletes the given entities supplied by a `Flowable`.
`io.reactivex.rxjava3.core.Completable`	`deleteAll(Iterable<? extends T> entities)` Deletes the given entities.
`io.reactivex.rxjava3.core.Completable`	`deleteAllById(Iterable<? extends ID> ids)` Deletes all instances of the type `T` with the given IDs.
`io.reactivex.rxjava3.core.Completable`	`deleteById(ID id)` Deletes the entity with the given id.
`io.reactivex.rxjava3.core.Single<Boolean>`	`existsById(ID id)` Returns whether an entity with the given id exists.
`io.reactivex.rxjava3.core.Single<Boolean>`	`existsById(io.reactivex.rxjava3.core.Single<ID> id)` Returns whether an entity with the given id, supplied by a `Single`, exists.
`io.reactivex.rxjava3.core.Flowable<T>`	`findAll()` Returns all instances of the type.
`io.reactivex.rxjava3.core.Flowable<T>`	`findAllById(io.reactivex.rxjava3.core.Flowable<ID> idStream)` Returns all instances of the type `T` with the given IDs supplied by a `Flowable`.
`io.reactivex.rxjava3.core.Flowable<T>`	`findAllById(Iterable<ID> ids)` Returns all instances of the type `T` with the given IDs.
`io.reactivex.rxjava3.core.Maybe<T>`	`findById(ID id)` Retrieves an entity by its id.
`io.reactivex.rxjava3.core.Maybe<T>`	`findById(io.reactivex.rxjava3.core.Single<ID> id)` Retrieves an entity by its id supplied by a `Single`.
`<S extends T> io.reactivex.rxjava3.core.Single<S>`	`save(S entity)` Saves a given entity.
`<S extends T> io.reactivex.rxjava3.core.Flowable<S>`	`saveAll(io.reactivex.rxjava3.core.Flowable<S> entityStream)` Saves all given entities.
`<S extends T> io.reactivex.rxjava3.core.Flowable<S>`	`saveAll(Iterable<S> entities)` Saves all given entities.

- Method Detail
  - save
```
<S extends T> io.reactivex.rxjava3.core.Single<S> save(S entity)
```
    Saves a given entity. Use the returned instance for further operations as the save operation might have changed the entity instance completely.
    
    Parameters:
    
    entity - must not be null.
    
    Returns:
    
    Single emitting the saved entity.
    
    Throws:
    
    IllegalArgumentException - in case the given entity is null.
  - saveAll
```
<S extends T> io.reactivex.rxjava3.core.Flowable<S> saveAll(Iterable<S> entities)
```
    Saves all given entities.
    
    Parameters:
    
    entities - must not be null.
    
    Returns:
    
    Flowable emitting the saved entities.
    
    Throws:
    
    IllegalArgumentException - in case the given entities or one of its entities is null.
  - saveAll
```
<S extends T> io.reactivex.rxjava3.core.Flowable<S> saveAll(io.reactivex.rxjava3.core.Flowable<S> entityStream)
```
    Saves all given entities.
    
    Parameters:
    
    entityStream - must not be null.
    
    Returns:
    
    Flowable emitting the saved entities.
    
    Throws:
    
    IllegalArgumentException - in case the given entityStream is null.
  - findById
```
io.reactivex.rxjava3.core.Maybe<T> findById(ID id)
```
    Retrieves an entity by its id.
    
    Parameters:
    
    id - must not be null.
    
    Returns:
    
    Maybe emitting the entity with the given id or Maybe.empty() if none found.
    
    Throws:
    
    IllegalArgumentException - in case the given id is null.
  - findById
```
io.reactivex.rxjava3.core.Maybe<T> findById(io.reactivex.rxjava3.core.Single<ID> id)
```
    Retrieves an entity by its id supplied by a Single.
    
    Parameters:
    
    id - must not be null. Uses the first emitted element to perform the find-query.
    
    Returns:
    
    Maybe emitting the entity with the given id or Maybe.empty() if none found.
    
    Throws:
    
    IllegalArgumentException - in case the given id is null.
  - existsById
```
io.reactivex.rxjava3.core.Single<Boolean> existsById(ID id)
```
    Returns whether an entity with the given id exists.
    
    Parameters:
    
    id - must not be null.
    
    Returns:
    
    Single emitting true if an entity with the given id exists, false otherwise.
    
    Throws:
    
    IllegalArgumentException - in case the given id is null.
  - existsById
```
io.reactivex.rxjava3.core.Single<Boolean> existsById(io.reactivex.rxjava3.core.Single<ID> id)
```
    Returns whether an entity with the given id, supplied by a Single, exists.
    
    Parameters:
    
    id - must not be null.
    
    Returns:
    
    Single emitting true if an entity with the given id exists, false otherwise.
    
    Throws:
    
    IllegalArgumentException - in case the given id is null.
  - findAll
```
io.reactivex.rxjava3.core.Flowable<T> findAll()
```
    Returns all instances of the type.
    
    Returns:
    
    Flowable emitting all entities.
  - findAllById
```
io.reactivex.rxjava3.core.Flowable<T> findAllById(Iterable<ID> ids)
```
    Returns all instances of the type T with the given IDs.
    If some or all ids are not found, no entities are returned for these IDs.
    Note that the order of elements in the result is not guaranteed.
    
    Parameters:
    
    ids - must not be null nor contain any null values.
    
    Returns:
    
    Flowable emitting the found entities. The size can be equal or less than the number of given ids.
    
    Throws:
    
    IllegalArgumentException - in case the given ids or one of its items is null.
  - findAllById
```
io.reactivex.rxjava3.core.Flowable<T> findAllById(io.reactivex.rxjava3.core.Flowable<ID> idStream)
```
    Returns all instances of the type T with the given IDs supplied by a Flowable.
    If some or all ids are not found, no entities are returned for these IDs.
    Note that the order of elements in the result is not guaranteed.
    
    Parameters:
    
    idStream - must not be null.
    
    Returns:
    
    Flowable emitting the found entities.
    
    Throws:
    
    IllegalArgumentException - in case the given idStream is null.
  - count
```
io.reactivex.rxjava3.core.Single<Long> count()
```
    Returns the number of entities available.
    
    Returns:
    
    Single emitting the number of entities.
  - deleteById
```
io.reactivex.rxjava3.core.Completable deleteById(ID id)
```
    Deletes the entity with the given id.
    
    Parameters:
    
    id - must not be null.
    
    Returns:
    
    Completable signaling when operation has completed.
    
    Throws:
    
    IllegalArgumentException - in case the given id is null.
  - delete
```
io.reactivex.rxjava3.core.Completable delete(T entity)
```
    Deletes a given entity.
    
    Parameters:
    
    entity - must not be null.
    
    Returns:
    
    Completable signaling when operation has completed.
    
    Throws:
    
    IllegalArgumentException - in case the given entity is null.
  - deleteAllById
```
io.reactivex.rxjava3.core.Completable deleteAllById(Iterable<? extends ID> ids)
```
    Deletes all instances of the type T with the given IDs.
    
    Parameters:
    
    ids - must not be null.
    
    Returns:
    
    Completable signaling when operation has completed.
    
    Throws:
    
    IllegalArgumentException - in case the given ids or one of its elements is null. null.
    
    Since:
    
    2.5
  - deleteAll
```
io.reactivex.rxjava3.core.Completable deleteAll(Iterable<? extends T> entities)
```
    Deletes the given entities.
    
    Parameters:
    
    entities - must not be null.
    
    Returns:
    
    Completable signaling when operation has completed.
    
    Throws:
    
    IllegalArgumentException - in case the given entities or one of its entities is null.
  - deleteAll
```
io.reactivex.rxjava3.core.Completable deleteAll(io.reactivex.rxjava3.core.Flowable<? extends T> entityStream)
```
    Deletes the given entities supplied by a Flowable.
    
    Parameters:
    
    entityStream - must not be null.
    
    Returns:
    
    Completable signaling when operation has completed.
    
    Throws:
    
    IllegalArgumentException - in case the given entityStream is null.
  - deleteAll
```
io.reactivex.rxjava3.core.Completable deleteAll()
```
    Deletes all entities managed by the repository.
    
    Returns:
    
    Completable signaling when operation has completed.

Interface RxJava3CrudRepository<T,ID>

Method Summary

Method Detail

save

saveAll

saveAll

findById

findById

existsById

existsById

findAll

findAllById

findAllById

count

deleteById

delete

deleteAllById

deleteAll

deleteAll

deleteAll