Package io.objectbox.reactive
Class DataSubscriptionImpl<T>
- java.lang.Object
-
- io.objectbox.reactive.DataSubscriptionImpl<T>
-
- All Implemented Interfaces:
DataSubscription
class DataSubscriptionImpl<T> extends java.lang.Object implements DataSubscription
-
-
Field Summary
Fields Modifier and Type Field Description private booleancanceledprivate DataObserver<T>observerprivate DataPublisher<T>publisherprivate java.lang.ObjectpublisherParam
-
Constructor Summary
Constructors Constructor Description DataSubscriptionImpl(DataPublisher<T> publisher, java.lang.Object publisherParam, DataObserver<T> observer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcancel()The Observer shall not receive anymore updates.booleanisCanceled()Current cancellation state of the subscription.
-
-
-
Field Detail
-
canceled
private volatile boolean canceled
-
publisher
private DataPublisher<T> publisher
-
publisherParam
private java.lang.Object publisherParam
-
observer
private DataObserver<T> observer
-
-
Constructor Detail
-
DataSubscriptionImpl
DataSubscriptionImpl(DataPublisher<T> publisher, @Nullable java.lang.Object publisherParam, DataObserver<T> observer)
-
-
Method Detail
-
cancel
public void cancel()
Description copied from interface:DataSubscriptionThe Observer shall not receive anymore updates.- Specified by:
cancelin interfaceDataSubscription
-
isCanceled
public boolean isCanceled()
Description copied from interface:DataSubscriptionCurrent cancellation state of the subscription.- Specified by:
isCanceledin interfaceDataSubscription
-
-