org.immutables.criteria.repository.reactive

Class ReactiveWatcher<T>

java.lang.Object

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

All Implemented Interfaces:

Queryable, Watcher<T,org.reactivestreams.Publisher<WatchEvent<T>>>

public final class ReactiveWatcher<T>
extends Object
implements Watcher<T,org.reactivestreams.Publisher<WatchEvent<T>>>, Queryable

Constructor Summary

Constructors

Constructor and Description
ReactiveWatcher(Criterion<?> criteria, Backend.Session session)

Method Summary

Modifier and Type	Method and Description
Query	query()
org.reactivestreams.Publisher<WatchEvent<T>>	watch()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveWatcher

public ReactiveWatcher(Criterion<?> criteria,
                       Backend.Session session)

Method Detail

watch

public org.reactivestreams.Publisher<WatchEvent<T>> watch()

query

public Query query()