public class SimpleFirestoreReactiveRepository<T> extends Object implements FirestoreReactiveRepository<T>
Constructor and Description |
---|
SimpleFirestoreReactiveRepository(FirestoreTemplate firestoreTemplate,
Class type) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
count() |
reactor.core.publisher.Mono<Void> |
delete(Object entity) |
reactor.core.publisher.Mono<Void> |
deleteAll() |
reactor.core.publisher.Mono<Void> |
deleteAll(Iterable entities) |
reactor.core.publisher.Mono<Void> |
deleteAll(org.reactivestreams.Publisher entityStream) |
reactor.core.publisher.Mono<Void> |
deleteAllById(Iterable<? extends String> ids) |
reactor.core.publisher.Mono<Void> |
deleteById(org.reactivestreams.Publisher idPublisher) |
reactor.core.publisher.Mono<Void> |
deleteById(String id) |
reactor.core.publisher.Mono<Boolean> |
existsById(org.reactivestreams.Publisher idPublisher) |
reactor.core.publisher.Mono<Boolean> |
existsById(String id) |
reactor.core.publisher.Flux<T> |
findAll() |
reactor.core.publisher.Flux<T> |
findAllById(Iterable<String> iterable) |
reactor.core.publisher.Flux<T> |
findAllById(org.reactivestreams.Publisher<String> idStream) |
reactor.core.publisher.Mono<T> |
findById(org.reactivestreams.Publisher<String> idPublisher) |
reactor.core.publisher.Mono<T> |
findById(String id) |
<S extends T> |
save(S entity) |
<S extends T> |
saveAll(Iterable<S> entities) |
<S extends T> |
saveAll(org.reactivestreams.Publisher<S> entityStream) |
public SimpleFirestoreReactiveRepository(FirestoreTemplate firestoreTemplate, Class type)
public <S extends T> reactor.core.publisher.Mono<S> save(S entity)
public <S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream)
public reactor.core.publisher.Mono<T> findById(org.reactivestreams.Publisher<String> idPublisher)
public reactor.core.publisher.Mono<Boolean> existsById(org.reactivestreams.Publisher idPublisher)
public reactor.core.publisher.Flux<T> findAll()
public reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<String> idStream)
public reactor.core.publisher.Mono<Long> count()
public reactor.core.publisher.Mono<Void> deleteById(org.reactivestreams.Publisher idPublisher)
public reactor.core.publisher.Mono<Void> deleteAll(org.reactivestreams.Publisher entityStream)
public reactor.core.publisher.Mono<Void> deleteAll()
Copyright © 2021. All rights reserved.