org.immutables.criteria.repository.reactive

Class ReactiveWritable<T>

java.lang.Object

org.immutables.criteria.repository.reactive.ReactiveWritable<T>

All Implemented Interfaces:

Facet, ReactiveRepository.Writable<T>, Writable<T,org.reactivestreams.Publisher<WriteResult>>

public class ReactiveWritable<T>
extends Object
implements ReactiveRepository.Writable<T>

Constructor Summary

Constructors

Constructor and Description
ReactiveWritable(Backend.Session backend)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<WriteResult>	delete(Criterion<T> criteria)
org.reactivestreams.Publisher<WriteResult>	insertAll(Iterable<? extends T> docs)
ReactiveUpdater<T>	update(Criterion<T> criterion)
org.reactivestreams.Publisher<WriteResult>	updateAll(Iterable<? extends T> docs)
org.reactivestreams.Publisher<WriteResult>	upsertAll(Iterable<? extends T> docs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.immutables.criteria.repository.Writable

insert, update, upsert

Constructor Detail

ReactiveWritable

public ReactiveWritable(Backend.Session backend)

Method Detail

insertAll

public org.reactivestreams.Publisher<WriteResult> insertAll(Iterable<? extends T> docs)

delete

public org.reactivestreams.Publisher<WriteResult> delete(Criterion<T> criteria)

upsertAll

public org.reactivestreams.Publisher<WriteResult> upsertAll(Iterable<? extends T> docs)

updateAll

public org.reactivestreams.Publisher<WriteResult> updateAll(Iterable<? extends T> docs)

update

public ReactiveUpdater<T> update(Criterion<T> criterion)