Uses of Interface
io.objectbox.reactive.DataObserver

Packages that use DataObserver

Package	Description
io.objectbox	ObjectBox is an an easy to use, object-oriented lightweight database and a full alternative to SQLite.
io.objectbox.query	Classes related to building a Query or PropertyQuery.
io.objectbox.reactive	Classes to configure a DataSubscription for observing Box or Query changes.

Uses of DataObserver in io.objectbox

Fields in io.objectbox declared as DataObserver

Modifier and Type	Field	Description
private DataObserver<java.lang.Class>	ObjectClassPublisher.PublishRequest.observer

Fields in io.objectbox with type parameters of type DataObserver

Modifier and Type	Field	Description
(package private) org.greenrobot.essentials.collections.MultimapSet<java.lang.Integer,DataObserver<java.lang.Class>>	ObjectClassPublisher.observersByEntityTypeId

Methods in io.objectbox with parameters of type DataObserver

Modifier and Type	Method	Description
void	ObjectClassPublisher.publishSingle(DataObserver<java.lang.Class> observer, java.lang.Object forClass)
private void	ObjectClassPublisher.queuePublishRequestAndScheduleRun(DataObserver<java.lang.Class> observer, int[] entityTypeIds)	Non-blocking: will just enqueue the changes for a separate thread.
void	ObjectClassPublisher.subscribe(DataObserver<java.lang.Class> observer, java.lang.Object forClass)
private void	ObjectClassPublisher.unsubscribe(DataObserver<java.lang.Class> observer, int entityTypeId)
void	ObjectClassPublisher.unsubscribe(DataObserver<java.lang.Class> observer, java.lang.Object forClass)	Removes the given observer from all object classes it added itself to earlier (forClass == null).

Constructors in io.objectbox with parameters of type DataObserver

Constructor	Description
PublishRequest(DataObserver<java.lang.Class> observer, int[] entityTypeIds)

Uses of DataObserver in io.objectbox.query

Classes in io.objectbox.query that implement DataObserver

Modifier and Type	Class	Description
private static class	QueryPublisher.SubscribedObservers<T>

Fields in io.objectbox.query declared as DataObserver

Modifier and Type	Field	Description
private DataObserver<java.lang.Class<T>>	QueryPublisher.objectClassObserver

Fields in io.objectbox.query with type parameters of type DataObserver

Modifier and Type	Field	Description
private java.util.Set<DataObserver<java.util.List<T>>>	QueryPublisher.observers
private java.util.Deque<DataObserver<java.util.List<T>>>	QueryPublisher.publishQueue

Methods in io.objectbox.query with parameters of type DataObserver

Modifier and Type	Method	Description
void	QueryPublisher.publishSingle(DataObserver<java.util.List<T>> observer, java.lang.Object param)
private void	QueryPublisher.queueObserverAndScheduleRun(DataObserver<java.util.List<T>> observer)	Non-blocking: will just enqueue the changes for a separate thread.
void	QueryPublisher.subscribe(DataObserver<java.util.List<T>> observer, java.lang.Object param)
void	QueryPublisher.unsubscribe(DataObserver<java.util.List<T>> observer, java.lang.Object param)

Uses of DataObserver in io.objectbox.reactive

Classes in io.objectbox.reactive that implement DataObserver

Modifier and Type	Class	Description
(package private) class	SubscriptionBuilder.ActionObserver	Wraps a DataObserver supplied to SubscriptionBuilder.observer(DataObserver) to support result transformation, an error observer or scheduler for result delivery.
class	WeakDataObserver<T>

Fields in io.objectbox.reactive declared as DataObserver

Modifier and Type	Field	Description
private DataObserver<T>	DataSubscriptionImpl.observer
private DataObserver<T>	SubscriptionBuilder.observer

Fields in io.objectbox.reactive with type parameters of type DataObserver

Modifier and Type	Field	Description
private java.lang.ref.WeakReference<DataObserver<T>>	WeakDataObserver.weakDelegate

Methods in io.objectbox.reactive that return DataObserver

Modifier and Type	Method	Description
DataObserver<T>	DelegatingObserver.getObserverDelegate()
DataObserver<T>	SubscriptionBuilder.ActionObserver.getObserverDelegate()
DataObserver<T>	WeakDataObserver.getObserverDelegate()

Methods in io.objectbox.reactive with parameters of type DataObserver

Modifier and Type	Method	Description
DataSubscription	SubscriptionBuilder.observer(DataObserver<T> observer)	Sets the observer for this subscription and requests the latest data to be delivered immediately.
void	DataPublisher.publishSingle(DataObserver<T> observer, java.lang.Object param)
static <T> void	DataPublisherUtils.removeObserverFromCopyOnWriteSet(java.util.Set<DataObserver<T>> observers, DataObserver<T> observer)	Observers may be wrapped by @DelegatingObserver, this will also remove those.
void	DataPublisher.subscribe(DataObserver<T> observer, java.lang.Object param)
void	DataPublisher.unsubscribe(DataObserver<T> observer, java.lang.Object param)

Method parameters in io.objectbox.reactive with type arguments of type DataObserver

Modifier and Type	Method	Description
static <T> void	DataPublisherUtils.removeObserverFromCopyOnWriteSet(java.util.Set<DataObserver<T>> observers, DataObserver<T> observer)	Observers may be wrapped by @DelegatingObserver, this will also remove those.

Constructors in io.objectbox.reactive with parameters of type DataObserver

Constructor	Description
DataSubscriptionImpl(DataPublisher<T> publisher, java.lang.Object publisherParam, DataObserver<T> observer)
WeakDataObserver(DataObserver<T> delegate)