Package at.qubic.api.service

Class ComputorService

java.lang.Object

at.qubic.api.service.ComputorService

public class ComputorService
extends Object

Constructor Summary

Constructors

Constructor	Description
ComputorService(Nodes nodes)
ComputorService(Nodes nodes, IdentityUtil identityUtil)
ComputorService(Nodes nodes, IdentityUtil idu, TransactionService transactionService)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Instant>	forceNetworkUpdateIfBefore(Instant updateIfBefore)
reactor.core.publisher.Mono<TickInfo>	getCurrentTickInfo()
reactor.core.publisher.Mono<Entity>	getEntity(String identity)
reactor.core.publisher.Flux<RespondOwnedAssets>	getOwnedAssets(String identity)
reactor.core.publisher.Flux<RespondPossessedAssets>	getPossessedAssets(String identity)
reactor.core.publisher.Mono<List<AssetOrder>>	getQxAskAssetOrders(String issuer, String assetName, long offset)
reactor.core.publisher.Mono<List<EntityOrder>>	getQxAskEntityOrders(String identity, long offset)
reactor.core.publisher.Mono<List<AssetOrder>>	getQxBidAssetOrders(String issuer, String assetName, long offset)
reactor.core.publisher.Mono<List<EntityOrder>>	getQxBidEntityOrders(String identity, long offset)
reactor.core.publisher.Mono<QxFees>	getQxFees()
reactor.core.publisher.Mono<TickData>	getTickData(int tick)
reactor.core.publisher.Flux<SignedTransaction>	getTickTransactions(int tick)
reactor.core.publisher.Mono<SignedTransaction>	sendTransaction(SignedTransaction signedTransaction)
reactor.core.publisher.Mono<SignedTransaction>	sendTransaction(String seed, String targetIdentity, long amount, int tickOffset)
reactor.core.publisher.Mono<SignedTransaction>	sendTransaction(Function<TickInfo,SignedTransaction> createTransactionFunction)

Methods inherited from class java.lang.Object

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

Constructor Details

ComputorService

public ComputorService(Nodes nodes)

ComputorService

public ComputorService(Nodes nodes,
 IdentityUtil identityUtil)

ComputorService

public ComputorService(Nodes nodes,
 IdentityUtil idu,
 TransactionService transactionService)

Method Details

getCurrentTickInfo

public reactor.core.publisher.Mono<TickInfo> getCurrentTickInfo()

getEntity

public reactor.core.publisher.Mono<Entity> getEntity(String identity)

sendTransaction

public reactor.core.publisher.Mono<SignedTransaction> sendTransaction(SignedTransaction signedTransaction)

sendTransaction

public reactor.core.publisher.Mono<SignedTransaction> sendTransaction(String seed,
 String targetIdentity,
 long amount,
 int tickOffset)

sendTransaction

public reactor.core.publisher.Mono<SignedTransaction> sendTransaction(Function<TickInfo,SignedTransaction> createTransactionFunction)

getTickData

public reactor.core.publisher.Mono<TickData> getTickData(int tick)

getTickTransactions

public reactor.core.publisher.Flux<SignedTransaction> getTickTransactions(int tick)

getOwnedAssets

public reactor.core.publisher.Flux<RespondOwnedAssets> getOwnedAssets(String identity)

getPossessedAssets

public reactor.core.publisher.Flux<RespondPossessedAssets> getPossessedAssets(String identity)

getQxFees

public reactor.core.publisher.Mono<QxFees> getQxFees()

getQxAskAssetOrders

public reactor.core.publisher.Mono<List<AssetOrder>> getQxAskAssetOrders(String issuer,
 String assetName,
 long offset)

getQxBidAssetOrders

public reactor.core.publisher.Mono<List<AssetOrder>> getQxBidAssetOrders(String issuer,
 String assetName,
 long offset)

getQxAskEntityOrders

public reactor.core.publisher.Mono<List<EntityOrder>> getQxAskEntityOrders(String identity,
 long offset)

getQxBidEntityOrders

public reactor.core.publisher.Mono<List<EntityOrder>> getQxBidEntityOrders(String identity,
 long offset)

forceNetworkUpdateIfBefore

public reactor.core.publisher.Mono<Instant> forceNetworkUpdateIfBefore(Instant updateIfBefore)