Package io.objectbox.reactive

Class SubscriptionBuilder.ActionObserver

java.lang.Object

io.objectbox.reactive.SubscriptionBuilder.ActionObserver

All Implemented Interfaces:

DataObserver<T>, DelegatingObserver<T>

Enclosing class:

SubscriptionBuilder<T>

class SubscriptionBuilder.ActionObserver
extends Object
implements DataObserver<T>, DelegatingObserver<T>

Wraps a DataObserver supplied to SubscriptionBuilder.observer(DataObserver) to support result transformation, an error observer or scheduler for result delivery.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	SubscriptionBuilder.ActionObserver.SchedulerRunOnChange
(package private) class	SubscriptionBuilder.ActionObserver.SchedulerRunOnError

Field Summary

Fields

Modifier and Type	Field	Description
private SubscriptionBuilder<T>.ActionObserver.SchedulerRunOnChange	schedulerRunOnData
private SubscriptionBuilder<T>.ActionObserver.SchedulerRunOnError	schedulerRunOnError
private final DataSubscriptionImpl	subscription

Constructor Summary

Constructors

Constructor	Description
ActionObserver(DataSubscriptionImpl subscription)

Method Summary

Modifier and Type	Method	Description
(package private) void	callOnData(T data)
private void	callOnError(Throwable th, String msgNoErrorObserver)
DataObserver<T>	getObserverDelegate()
void	onData(T data)	Called when data changed.
private void	transformAndContinue(T data)	Runs on the thread of the onData(Object) caller to ensure data is delivered in the same order as onData(Object) was called, to prevent delivering stale data.

Methods inherited from class java.lang.Object

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

Field Details

subscription

private final DataSubscriptionImpl subscription

schedulerRunOnError

private SubscriptionBuilder<T>.ActionObserver.SchedulerRunOnError schedulerRunOnError

schedulerRunOnData

private SubscriptionBuilder<T>.ActionObserver.SchedulerRunOnChange schedulerRunOnData

Constructor Details

ActionObserver

public ActionObserver(DataSubscriptionImpl subscription)

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>

transformAndContinue

private void transformAndContinue(T data)

Runs on the thread of the onData(Object) caller to ensure data is delivered in the same order as onData(Object) was called, to prevent delivering stale data.

For both ObjectClassPublisher and QueryPublisher this is the asynchronous thread publish requests are processed on.

This could be optimized in the future to allow parallel execution, but this would require an ordering mechanism for the transformed data.

callOnError

private void callOnError(Throwable th,
 String msgNoErrorObserver)

callOnData

void callOnData(T data)

getObserverDelegate

public DataObserver<T> getObserverDelegate()

Specified by:

getObserverDelegate in interface DelegatingObserver<T>