Package io.objectbox.reactive

Class DataSubscriptionImpl<T>

java.lang.Object

io.objectbox.reactive.DataSubscriptionImpl<T>

All Implemented Interfaces:

DataSubscription

class DataSubscriptionImpl<T>
extends Object
implements DataSubscription

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	canceled
private DataObserver<T>	observer
private DataPublisher<T>	publisher
private Object	publisherParam

Constructor Summary

Constructors

Constructor	Description
DataSubscriptionImpl(DataPublisher<T> publisher, Object publisherParam, DataObserver<T> observer)

Method Summary

Modifier and Type	Method	Description
void	cancel()	The Observer shall not receive anymore updates.
boolean	isCanceled()	Current cancellation state of the subscription.

Methods inherited from class java.lang.Object

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

Field Details

canceled

private volatile boolean canceled

publisher

private DataPublisher<T> publisher

publisherParam

private Object publisherParam

observer

private DataObserver<T> observer

Constructor Details

DataSubscriptionImpl

DataSubscriptionImpl(DataPublisher<T> publisher,
 @Nullable
 Object publisherParam,
 DataObserver<T> observer)

Method Details

cancel

public void cancel()

Description copied from interface: DataSubscription

The Observer shall not receive anymore updates.

Specified by:

cancel in interface DataSubscription

isCanceled

public boolean isCanceled()

Description copied from interface: DataSubscription

Current cancellation state of the subscription.

Specified by:

isCanceled in interface DataSubscription