SimpleReactiveElasticsearchRepository (Spring Data Elasticsearch 4.0.1.RELEASE API)

java.lang.Object
- org.springframework.data.elasticsearch.repository.support.SimpleReactiveElasticsearchRepository<T,ID>

All Implemented Interfaces:

ReactiveElasticsearchRepository<T,ID>, ReactiveCrudRepository<T,ID>, ReactiveSortingRepository<T,ID>, Repository<T,ID>
```
public class SimpleReactiveElasticsearchRepository<T,ID>
extends Object
implements ReactiveElasticsearchRepository<T,ID>
```
Since:

3.2

Author:

Christoph Strobl, Peter-Josef Meisch, Aleksei Arsenev

Constructor Summary

Constructors
Constructor and Description
`SimpleReactiveElasticsearchRepository(ElasticsearchEntityInformation<T,ID> entityInformation, ReactiveElasticsearchOperations elasticsearchOperations)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`reactor.core.publisher.Mono<Long>`	`count()`
`reactor.core.publisher.Mono<Void>`	`delete(T entity)`
`reactor.core.publisher.Mono<Void>`	`deleteAll()`
`reactor.core.publisher.Mono<Void>`	`deleteAll(Iterable<? extends T> entities)`
`reactor.core.publisher.Mono<Void>`	`deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)`
`reactor.core.publisher.Mono<Void>`	`deleteById(ID id)`
`reactor.core.publisher.Mono<Void>`	`deleteById(org.reactivestreams.Publisher<ID> id)`
`reactor.core.publisher.Mono<Boolean>`	`existsById(ID id)`
`reactor.core.publisher.Mono<Boolean>`	`existsById(org.reactivestreams.Publisher<ID> id)`
`reactor.core.publisher.Flux<T>`	`findAll()`
`reactor.core.publisher.Flux<T>`	`findAll(Sort sort)`
`reactor.core.publisher.Flux<T>`	`findAllById(Iterable<ID> ids)`
`reactor.core.publisher.Flux<T>`	`findAllById(org.reactivestreams.Publisher<ID> idStream)`
`reactor.core.publisher.Mono<T>`	`findById(ID id)`
`reactor.core.publisher.Mono<T>`	`findById(org.reactivestreams.Publisher<ID> id)`
`<S extends T> reactor.core.publisher.Mono<S>`	`save(S entity)`
`<S extends T> reactor.core.publisher.Flux<S>`	`saveAll(Iterable<S> entities)`
`<S extends T> reactor.core.publisher.Flux<S>`	`saveAll(org.reactivestreams.Publisher<S> entityStream)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleReactiveElasticsearchRepository

public SimpleReactiveElasticsearchRepository(ElasticsearchEntityInformation<T,ID> entityInformation,
                                             ReactiveElasticsearchOperations elasticsearchOperations)

Method Detail

save

public <S extends T> reactor.core.publisher.Mono<S> save(S entity)

Specified by:: save in interface ReactiveCrudRepository<T,ID>

saveAll

public <S extends T> reactor.core.publisher.Flux<S> saveAll(Iterable<S> entities)

Specified by:: saveAll in interface ReactiveCrudRepository<T,ID>

saveAll

public <S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream)

Specified by:: saveAll in interface ReactiveCrudRepository<T,ID>

findById
```
public reactor.core.publisher.Mono<T> findById(ID id)
```
Specified by:

findById in interface ReactiveCrudRepository<T,ID>

findById

public reactor.core.publisher.Mono<T> findById(org.reactivestreams.Publisher<ID> id)

Specified by:: findById in interface ReactiveCrudRepository<T,ID>

existsById
```
public reactor.core.publisher.Mono<Boolean> existsById(ID id)
```
Specified by:

existsById in interface ReactiveCrudRepository<T,ID>

existsById

public reactor.core.publisher.Mono<Boolean> existsById(org.reactivestreams.Publisher<ID> id)

Specified by:: existsById in interface ReactiveCrudRepository<T,ID>

findAll
```
public reactor.core.publisher.Flux<T> findAll()
```
Specified by:

findAll in interface ReactiveCrudRepository<T,ID>

findAll
```
public reactor.core.publisher.Flux<T> findAll(Sort sort)
```
Specified by:

findAll in interface ReactiveSortingRepository<T,ID>

findAllById
```
public reactor.core.publisher.Flux<T> findAllById(Iterable<ID> ids)
```
Specified by:

findAllById in interface ReactiveCrudRepository<T,ID>

findAllById

public reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<ID> idStream)

Specified by:: findAllById in interface ReactiveCrudRepository<T,ID>

count
```
public reactor.core.publisher.Mono<Long> count()
```
Specified by:

count in interface ReactiveCrudRepository<T,ID>

deleteById
```
public reactor.core.publisher.Mono<Void> deleteById(ID id)
```
Specified by:

deleteById in interface ReactiveCrudRepository<T,ID>

deleteById

public reactor.core.publisher.Mono<Void> deleteById(org.reactivestreams.Publisher<ID> id)

Specified by:: deleteById in interface ReactiveCrudRepository<T,ID>

delete
```
public reactor.core.publisher.Mono<Void> delete(T entity)
```
Specified by:

delete in interface ReactiveCrudRepository<T,ID>

deleteAll

public reactor.core.publisher.Mono<Void> deleteAll(Iterable<? extends T> entities)

Specified by:: deleteAll in interface ReactiveCrudRepository<T,ID>

deleteAll

public reactor.core.publisher.Mono<Void> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)

Specified by:: deleteAll in interface ReactiveCrudRepository<T,ID>

deleteAll
```
public reactor.core.publisher.Mono<Void> deleteAll()
```
Specified by:

deleteAll in interface ReactiveCrudRepository<T,ID>

Class SimpleReactiveElasticsearchRepository<T,ID>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

SimpleReactiveElasticsearchRepository

Method Detail

save

saveAll

saveAll

findById

findById

existsById

existsById

findAll

findAll

findAllById

findAllById

count

deleteById

deleteById

delete

deleteAll

deleteAll

deleteAll