1 | package pl.zankowski.iextrading4j.client.sse.request.marketdata; | |
2 | ||
3 | import pl.zankowski.iextrading4j.api.marketdata.DeepResult; | |
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 DeepSseRequestBuilder extends AbstractDeepSseRequestBuilder<List<DeepAsyncResponse<DeepResult>>, | |
13 | DeepSseRequestBuilder> { | |
14 | ||
15 | public DeepSseRequestBuilder() { | |
16 | this.addChannel(DeepChannel.DEEP); | |
17 | } | |
18 | ||
19 | @Override | |
20 | public SseRequest<List<DeepAsyncResponse<DeepResult>>> build() { | |
21 |
1
1. build : replaced return value with null for pl/zankowski/iextrading4j/client/sse/request/marketdata/DeepSseRequestBuilder::build → KILLED |
return SseRequestBuilder.<List<DeepAsyncResponse<DeepResult>>>builder() |
22 | .withPath("/deep") | |
23 | .withResponse(new GenericType<List<DeepAsyncResponse<DeepResult>>>() {}) | |
24 | .addQueryParam(CHANNEL_PARAM, getChannels()) | |
25 | .addQueryParam(SYMBOL_PARAM, getSymbol()) | |
26 | .addQueryParam(NO_SNAPSHOT_PARAM, isNoSnapshot()) | |
27 | .build(); | |
28 | } | |
29 | ||
30 | } | |
31 | ||
Mutations | ||
21 |
1.1 |