com.microstrategy.usher

Class ClearRegisteredRegionUseCase

java.lang.Object

com.microstrategy.usher.ClearRegisteredRegionUseCase

public class ClearRegisteredRegionUseCase
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected io.reactivex.disposables.Disposable	disposable
protected com.microstrategy.usher.PostExecutionThread	postExecutionThread
protected com.microstrategy.usher.ThreadExecutor	threadExecutor

Constructor Summary

Constructors

Constructor and Description
ClearRegisteredRegionUseCase(com.microstrategy.usher.ThreadExecutor threadExecutor, com.microstrategy.usher.PostExecutionThread postExecutionThread, com.microstrategy.usher.RegionCachedRepository googlePlayServiceRegionRepository)

Method Summary

Modifier and Type	Method and Description
io.reactivex.Completable	build()
<S extends io.reactivex.CompletableObserver & io.reactivex.disposables.Disposable> void	execute(S useCaseDisposable)
boolean	isUnsubscribed()
protected DomainException	retrieveDomainException(java.lang.Throwable throwable)
io.reactivex.Completable	transformError(java.lang.Throwable throwable)
void	unsubscribe()

Methods inherited from class java.lang.Object

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

Field Detail

threadExecutor

protected final com.microstrategy.usher.ThreadExecutor threadExecutor

postExecutionThread

protected final com.microstrategy.usher.PostExecutionThread postExecutionThread

disposable

protected io.reactivex.disposables.Disposable disposable

Constructor Detail

ClearRegisteredRegionUseCase

@Inject
public ClearRegisteredRegionUseCase(com.microstrategy.usher.ThreadExecutor threadExecutor,
                                            com.microstrategy.usher.PostExecutionThread postExecutionThread,
                                            com.microstrategy.usher.RegionCachedRepository googlePlayServiceRegionRepository)

Method Detail

build

public io.reactivex.Completable build()

execute

public <S extends io.reactivex.CompletableObserver & io.reactivex.disposables.Disposable> void execute(S useCaseDisposable)

transformError

public io.reactivex.Completable transformError(java.lang.Throwable throwable)

unsubscribe

public void unsubscribe()

retrieveDomainException

@Nullable
protected DomainException retrieveDomainException(java.lang.Throwable throwable)

isUnsubscribed

public boolean isUnsubscribed()