1 | package pl.zankowski.iextrading4j.client.sse.request.marketdata; | |
2 | ||
3 | import pl.zankowski.iextrading4j.api.marketdata.Trade; | |
4 | import pl.zankowski.iextrading4j.client.socket.request.marketdata.deep.DeepAsyncResponse; | |
5 | import pl.zankowski.iextrading4j.client.socket.request.marketdata.deep.DeepChannel; | |
6 | import pl.zankowski.iextrading4j.client.sse.manager.SseRequest; | |
7 | import pl.zankowski.iextrading4j.client.sse.manager.SseRequestBuilder; | |
8 | ||
9 | import javax.ws.rs.core.GenericType; | |
10 | import java.util.List; | |
11 | ||
12 | public class TradesSseRequestBuilder extends AbstractDeepSseRequestBuilder<List<DeepAsyncResponse<Trade>>, | |
13 | TradesSseRequestBuilder> { | |
14 | ||
15 | public TradesSseRequestBuilder() { | |
16 | this.addChannel(DeepChannel.TRADES); | |
17 | } | |
18 | ||
19 | @Override | |
20 | public SseRequest<List<DeepAsyncResponse<Trade>>> build() { | |
21 |
1
1. build : replaced return value with null for pl/zankowski/iextrading4j/client/sse/request/marketdata/TradesSseRequestBuilder::build → KILLED |
return SseRequestBuilder.<List<DeepAsyncResponse<Trade>>>builder() |
22 | .withPath("/deep") | |
23 | .withResponse(new GenericType<List<DeepAsyncResponse<Trade>>>() { | |
24 | }) | |
25 | .addQueryParam(CHANNEL_PARAM, getChannels()) | |
26 | .addQueryParam(SYMBOL_PARAM, getSymbol()) | |
27 | .addQueryParam(NO_SNAPSHOT_PARAM, isNoSnapshot()) | |
28 | .build(); | |
29 | } | |
30 | ||
31 | } | |
Mutations | ||
21 |
1.1 |