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 final DataObserver<Class>	ObjectClassPublisher.PublishRequest.observer

Fields in io.objectbox with type parameters of type DataObserver

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

Methods in io.objectbox with parameters of type DataObserver

Modifier and Type	Method	Description
void	ObjectClassPublisher.publishSingle(DataObserver<Class> observer, Object forClass)
private void	ObjectClassPublisher.queuePublishRequestAndScheduleRun(DataObserver<Class> observer, int[] entityTypeIds)	Non-blocking: will just enqueue the changes for a separate thread.
void	ObjectClassPublisher.subscribe(DataObserver<Class> observer, Object forClass)
private void	ObjectClassPublisher.unsubscribe(DataObserver<Class> observer, int entityTypeId)
void	ObjectClassPublisher.unsubscribe(DataObserver<Class> observer, 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

Modifier	Constructor	Description
(package private)	PublishRequest(DataObserver<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<Class<T>>	QueryPublisher.objectClassObserver

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

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

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

Modifier and Type	Method	Description
void	QueryPublisher.publishSingle(DataObserver<List<T>> observer, Object param)
private void	QueryPublisher.queueObserverAndScheduleRun(DataObserver<List<T>> observer)	Non-blocking: will just enqueue the changes for a separate thread.
void	QueryPublisher.subscribe(DataObserver<List<T>> observer, Object param)
void	QueryPublisher.unsubscribe(DataObserver<List<T>> observer, 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 final 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, Object param)
static <T> void	DataPublisherUtils.removeObserverFromCopyOnWriteSet(Set<DataObserver<T>> observers, DataObserver<T> observer)	Observers may be wrapped by @DelegatingObserver, this will also remove those.
void	DataPublisher.subscribe(DataObserver<T> observer, Object param)
void	DataPublisher.unsubscribe(DataObserver<T> observer, Object param)

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

Modifier and Type	Method	Description
static <T> void	DataPublisherUtils.removeObserverFromCopyOnWriteSet(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

Modifier	Constructor	Description
(package private)	DataSubscriptionImpl(DataPublisher<T> publisher, Object publisherParam, DataObserver<T> observer)
(package private)	WeakDataObserver(DataObserver<T> delegate)