Package io.objectbox.reactive

Class WeakDataObserver<T>

java.lang.Object

io.objectbox.reactive.WeakDataObserver<T>

All Implemented Interfaces:

DataObserver<T>, DelegatingObserver

@Internal
public class WeakDataObserver<T>
extends Object
implements DataObserver<T>, DelegatingObserver

Field Summary

Fields

Modifier and Type	Field	Description
private DataSubscription	subscription
private final WeakReference<DataObserver<T>>	weakDelegate

Constructor Summary

Constructors

Constructor	Description
WeakDataObserver(DataObserver<T> delegate)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object other)
DataObserver<T>	getObserverDelegate()
int	hashCode()
void	onData(T data)	Called when data changed.
void	setSubscription(DataSubscription subscription)

Methods inherited from class java.lang.Object

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

Field Details

weakDelegate

private final WeakReference<DataObserver<T>> weakDelegate

subscription

private DataSubscription subscription

Constructor Details

WeakDataObserver

WeakDataObserver(DataObserver<T> delegate)

Method Details

onData

public void onData(T data)

Description copied from interface: DataObserver

Called when data changed.

Exception note: if this method throws an exception, it can be reacted on via SubscriptionBuilder.onError(ErrorObserver).

Specified by:

onData in interface DataObserver<T>

getObserverDelegate

public DataObserver<T> getObserverDelegate()

Specified by:

getObserverDelegate in interface DelegatingObserver<T>

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

setSubscription

public void setSubscription(DataSubscription subscription)