org.springframework.data.repository.reactive

Interface RxJava1CrudRepository<T,ID extends Serializable>

All Superinterfaces:

Repository<T,ID>

All Known Subinterfaces:

RxJava1SortingRepository<T,ID>

@NoRepositoryBean
public interface RxJava1CrudRepository<T,ID extends Serializable>
extends Repository<T,ID>

Interface for generic CRUD operations on a repository for a specific type. This repository follows reactive paradigms and uses RxJava 1 types.

Since:

2.0

Author:

Mark Paluch

See Also:

Single, Observable

Method Summary

Modifier and Type	Method and Description
rx.Single<Long>	count() Returns the number of entities available.
rx.Completable	delete(ID id) Deletes the entity with the given id.
rx.Completable	delete(Iterable<? extends T> entities) Deletes the given entities.
rx.Completable	delete(rx.Observable<? extends T> entityStream) Deletes the given entities.
rx.Completable	delete(T entity) Deletes a given entity.
rx.Completable	deleteAll() Deletes all entities managed by the repository.
rx.Single<Boolean>	exists(ID id) Returns whether an entity with the given id exists.
rx.Single<Boolean>	exists(rx.Single<ID> id) Returns whether an entity with the given id exists supplied by a Single.
rx.Observable<T>	findAll() Returns all instances of the type.
rx.Observable<T>	findAll(Iterable<ID> ids) Returns all instances of the type with the given IDs.
rx.Observable<T>	findAll(rx.Observable<ID> idStream) Returns all instances of the type with the given IDs.
rx.Observable<T>	findOne(ID id) Retrieves an entity by its id.
rx.Observable<T>	findOne(rx.Single<ID> id) Retrieves an entity by its id supplied by a Single.
<S extends T> rx.Observable<S>	save(Iterable<S> entities) Saves all given entities.
<S extends T> rx.Observable<S>	save(rx.Observable<S> entityStream) Saves all given entities.
<S extends T> rx.Single<S>	save(S entity) Saves a given entity.

Method Detail

save

<S extends T> rx.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 -

Returns:

the saved entity

save

<S extends T> rx.Observable<S> save(Iterable<S> entities)

Saves all given entities.

Parameters:

entities - must not be null.

Returns:

the saved entities

Throws:

IllegalArgumentException - in case the given entity is null.

save

<S extends T> rx.Observable<S> save(rx.Observable<S> entityStream)

Saves all given entities.

Parameters:

entityStream - must not be null.

Returns:

the saved entities

Throws:

IllegalArgumentException - in case the given Publisher is null.

findOne

rx.Observable<T> findOne(ID id)

Retrieves an entity by its id.

Parameters:

id - must not be null.

Returns:

the entity with the given id or null if none found

Throws:

IllegalArgumentException - if id is null

findOne

rx.Observable<T> findOne(rx.Single<ID> id)

Retrieves an entity by its id supplied by a Single.

Parameters:

id - must not be null.

Returns:

the entity with the given id or null if none found

Throws:

IllegalArgumentException - if id is null

exists

rx.Single<Boolean> exists(ID id)

Returns whether an entity with the given id exists.

Parameters:

id - must not be null.

Returns:

true if an entity with the given id exists, false otherwise

Throws:

IllegalArgumentException - if id is null

exists

rx.Single<Boolean> exists(rx.Single<ID> id)

Returns whether an entity with the given id exists supplied by a Single.

Parameters:

id - must not be null.

Returns:

true if an entity with the given id exists, false otherwise

Throws:

IllegalArgumentException - if id is null

findAll

rx.Observable<T> findAll()

Returns all instances of the type.

Returns:

all entities

findAll

rx.Observable<T> findAll(Iterable<ID> ids)

Returns all instances of the type with the given IDs.

Parameters:

ids -

Returns:

findAll

rx.Observable<T> findAll(rx.Observable<ID> idStream)

Returns all instances of the type with the given IDs.

Parameters:

idStream -

Returns:

count

rx.Single<Long> count()

Returns the number of entities available.

Returns:

the number of entities

delete

rx.Completable delete(ID id)

Deletes the entity with the given id.

Parameters:

id - must not be null.

Throws:

IllegalArgumentException - in case the given id is null

delete

rx.Completable delete(T entity)

Deletes a given entity.

Parameters:

entity -

Throws:

IllegalArgumentException - in case the given entity is null.

delete

rx.Completable delete(Iterable<? extends T> entities)

Deletes the given entities.

Parameters:

entities -

Throws:

IllegalArgumentException - in case the given Iterable is null.

delete

rx.Completable delete(rx.Observable<? extends T> entityStream)

Deletes the given entities.

Parameters:

entityStream -

Throws:

IllegalArgumentException - in case the given Publisher is null.

deleteAll

rx.Completable deleteAll()

Deletes all entities managed by the repository.