io.micronaut.data.tck.repositories

Interface PersonReactiveRepository

All Superinterfaces:

GenericRepository<Person,java.lang.Long>, RxJavaCrudRepository<Person,java.lang.Long>

public interface PersonReactiveRepository
extends RxJavaCrudRepository<Person,java.lang.Long>

Method Summary

Modifier and Type	Method and Description
io.reactivex.Single<java.lang.Integer>	count(java.lang.String name)
io.reactivex.Single<java.lang.Long>	deleteByNameLike(java.lang.String name)
io.reactivex.Maybe<Person>	findByName(java.lang.String name)
io.reactivex.Observable<Person>	findByNameLike(java.lang.String name)
io.reactivex.Single<Person>	getById(java.lang.Long id)
io.reactivex.Flowable<Person>	list(Pageable pageable)
io.reactivex.Single<Person>	save(java.lang.String name, int age)
io.reactivex.Completable	updatePerson(java.lang.Long id, java.lang.String name)

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

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

Method Detail

save

io.reactivex.Single<Person> save(java.lang.String name,
                                 int age)

getById

io.reactivex.Single<Person> getById(java.lang.Long id)

updatePerson

io.reactivex.Completable updatePerson(@Id
                                      java.lang.Long id,
                                      @Parameter(value="name")
                                      java.lang.String name)

list

io.reactivex.Flowable<Person> list(Pageable pageable)

count

io.reactivex.Single<java.lang.Integer> count(java.lang.String name)

findByName

@Nullable
io.reactivex.Maybe<Person> findByName(java.lang.String name)

deleteByNameLike

io.reactivex.Single<java.lang.Long> deleteByNameLike(java.lang.String name)

findByNameLike

io.reactivex.Observable<Person> findByNameLike(java.lang.String name)