Package org.stellar.sdk.requests
Class TradesRequestBuilder
java.lang.Object
org.stellar.sdk.requests.RequestBuilder
org.stellar.sdk.requests.TradesRequestBuilder
Builds requests connected to trades.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.stellar.sdk.requests.RequestBuilder
RequestBuilder.Order
-
Constructor Summary
ConstructorDescriptionTradesRequestBuilder
(okhttp3.OkHttpClient httpClient, okhttp3.HttpUrl serverURI) -
Method Summary
Modifier and TypeMethodDescriptioncounterAsset
(Asset asset) Setscursor
parameter on the request.execute()
Build and execute request.static Page
<TradeResponse> execute
(okhttp3.OkHttpClient httpClient, okhttp3.HttpUrl uri) forAccount
(@NonNull String account) Builds request toGET /accounts/{account}/trades
forLiquidityPool
(String liquidityPoolId) Builds request toGET /liquidity_pools/{poolID}/trades
forTradeType
(@NonNull String tradeType) Returns all trades that of a specific type.limit
(int number) Setslimit
parameter on the request.stream
(EventListener<TradeResponse> listener) An overloaded version ofstream(EventListener, long)
with default reconnect timeout.stream
(EventListener<TradeResponse> listener, long reconnectTimeout) Allows to stream SSE events from horizon.Methods inherited from class org.stellar.sdk.requests.RequestBuilder
order, setAssetParameter, setAssetsParameter
-
Constructor Details
-
TradesRequestBuilder
public TradesRequestBuilder(okhttp3.OkHttpClient httpClient, okhttp3.HttpUrl serverURI)
-
-
Method Details
-
baseAsset
-
counterAsset
-
forAccount
Builds request toGET /accounts/{account}/trades
- Parameters:
account
- Account for which to get trades- See Also:
-
forLiquidityPool
Builds request toGET /liquidity_pools/{poolID}/trades
- Parameters:
liquidityPoolId
- Liquidity pool for which to get trades- See Also:
-
forTradeType
Returns all trades that of a specific type.- Parameters:
tradeType
- type- Returns:
- current
TradesRequestBuilder
instance - See Also:
-
execute
- Parameters:
httpClient
-OkHttpClient
to use to send the request.uri
-HttpUrl
URI to send the request to.- Returns:
Page
ofTradeResponse
- Throws:
NetworkException
- All the exceptions below are subclasses of NetworkErrorBadRequestException
- if the request fails due to a bad request (4xx)BadResponseException
- if the request fails due to a bad response from the server (5xx)TooManyRequestsException
- if the request fails due to too many requests sent to the serverRequestTimeoutException
- When Horizon returns aTimeout
or connection timeout occurredUnknownResponseException
- if the server returns an unknown status codeConnectionErrorException
- When the request cannot be executed due to cancellation or connectivity problems, etc.
-
execute
Build and execute request.- Returns:
Page
ofTradeResponse
- Throws:
NetworkException
- All the exceptions below are subclasses of NetworkErrorBadRequestException
- if the request fails due to a bad request (4xx)BadResponseException
- if the request fails due to a bad response from the server (5xx)TooManyRequestsException
- if the request fails due to too many requests sent to the serverRequestTimeoutException
- When Horizon returns aTimeout
or connection timeout occurredUnknownResponseException
- if the server returns an unknown status codeConnectionErrorException
- When the request cannot be executed due to cancellation or connectivity problems, etc.
-
offerId
-
cursor
Description copied from class:RequestBuilder
Setscursor
parameter on the request. A cursor is a value that points to a specific location in a collection of resources. The cursor attribute itself is an opaque value meaning that users should not try to parse it.- Overrides:
cursor
in classRequestBuilder
- Parameters:
token
- A cursor is a value that points to a specific location in a collection of resources.- See Also:
-
limit
Description copied from class:RequestBuilder
Setslimit
parameter on the request. It defines maximum number of records to return. For range and default values check documentation of the endpoint requested.- Overrides:
limit
in classRequestBuilder
- Parameters:
number
- maxium number of records to return
-
stream
public SSEStream<TradeResponse> stream(EventListener<TradeResponse> listener, long reconnectTimeout) Allows to stream SSE events from horizon. Certain endpoints in Horizon can be called in streaming mode using Server-Sent Events. This mode will keep the connection to horizon open and horizon will continue to return responses as ledgers close.- Parameters:
listener
-EventListener
implementation withTradeResponse
typereconnectTimeout
- Custom stream connection timeout in ms- Returns:
- EventSource object, so you can
close()
connection when not needed anymore - See Also:
-
stream
An overloaded version ofstream(EventListener, long)
with default reconnect timeout.
-