io.nem.symbol.sdk.infrastructure.okhttp

Class AbstractRepositoryOkHttpImpl

java.lang.Object

io.nem.symbol.sdk.infrastructure.okhttp.AbstractRepositoryOkHttpImpl

Direct Known Subclasses:

AccountRepositoryOkHttpImpl, BlockRepositoryOkHttpImpl, ChainRepositoryOkHttpImpl, FinalizationRepositoryOkHttpImpl, HashLockRepositoryOkHttpImpl, MetadataRepositoryOkHttpImpl, MosaicRepositoryOkHttpImpl, MultisigRepositoryOkHttpImpl, NamespaceRepositoryOkHttpImpl, NetworkRepositoryOkHttpImpl, NodeRepositoryOkHttpImpl, ReceiptRepositoryOkHttpImpl, RestrictionAccountRepositoryOkHttpImpl, RestrictionMosaicRepositoryOkHttpImpl, SecretLockRepositoryOkHttpImpl, TransactionRepositoryOkHttpImpl, TransactionStatusRepositoryOkHttpImpl

public abstract class AbstractRepositoryOkHttpImpl
extends java.lang.Object

Created by fernando on 30/07/19.

Constructor Summary

Constructors

Constructor and Description
AbstractRepositoryOkHttpImpl(io.nem.symbol.sdk.openapi.okhttp_gson.invoker.ApiClient apiClient)

Method Summary

Modifier and Type	Method and Description
<T> io.reactivex.Observable<T>	call(java.util.concurrent.Callable<T> callback)
<T,R> io.reactivex.Observable<R>	call(java.util.concurrent.Callable<T> callback, io.reactivex.functions.Function<? super T,? extends R> mapper)
<T,R> io.reactivex.Observable<java.util.List<R>>	callList(java.util.concurrent.Callable<java.util.List<T>> callback, java.util.function.Function<T,R> mapper)
<T> io.reactivex.Observable<T>	exceptionHandling(io.reactivex.Observable<T> observable)
RepositoryCallException	exceptionHandling(java.lang.Throwable e)
static int	extractStatusCodeFromException(java.lang.Throwable e)
JsonHelper	getJsonHelper()
<T> io.reactivex.Observable<T>	onError(java.lang.Throwable e)
protected java.lang.String	toDto(Address address)
protected java.lang.String	toDto(java.math.BigInteger number)
protected java.lang.String	toDto(MosaicId mosaicId)
protected io.nem.symbol.sdk.openapi.okhttp_gson.model.Order	toDto(OrderBy order)
protected java.lang.String	toDto(PublicKey publicKey)
MerkleStateInfo	toMerkleStateInfo(io.nem.symbol.sdk.openapi.okhttp_gson.model.MerkleStateInfoDTO dto)
protected <T> Page<T>	toPage(io.nem.symbol.sdk.openapi.okhttp_gson.model.Pagination pagination, java.util.List<T> data)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractRepositoryOkHttpImpl

public AbstractRepositoryOkHttpImpl(io.nem.symbol.sdk.openapi.okhttp_gson.invoker.ApiClient apiClient)

Method Detail

call

public <T> io.reactivex.Observable<T> call(java.util.concurrent.Callable<T> callback)

call

public <T,R> io.reactivex.Observable<R> call(java.util.concurrent.Callable<T> callback,
                                             io.reactivex.functions.Function<? super T,? extends R> mapper)

callList

public <T,R> io.reactivex.Observable<java.util.List<R>> callList(java.util.concurrent.Callable<java.util.List<T>> callback,
                                                                 java.util.function.Function<T,R> mapper)

exceptionHandling

public RepositoryCallException exceptionHandling(java.lang.Throwable e)

extractStatusCodeFromException

public static int extractStatusCodeFromException(java.lang.Throwable e)

onError

public <T> io.reactivex.Observable<T> onError(java.lang.Throwable e)

exceptionHandling

public <T> io.reactivex.Observable<T> exceptionHandling(io.reactivex.Observable<T> observable)

toDto

protected io.nem.symbol.sdk.openapi.okhttp_gson.model.Order toDto(OrderBy order)

toDto

protected java.lang.String toDto(PublicKey publicKey)

toDto

protected java.lang.String toDto(MosaicId mosaicId)

toDto

protected java.lang.String toDto(Address address)

toDto

protected java.lang.String toDto(java.math.BigInteger number)

toPage

protected <T> Page<T> toPage(io.nem.symbol.sdk.openapi.okhttp_gson.model.Pagination pagination,
                             java.util.List<T> data)

toMerkleStateInfo

public MerkleStateInfo toMerkleStateInfo(io.nem.symbol.sdk.openapi.okhttp_gson.model.MerkleStateInfoDTO dto)

getJsonHelper

public JsonHelper getJsonHelper()