1 | package pl.zankowski.iextrading4j.client.socket.request.marketdata.deep; | |
2 | ||
3 | import pl.zankowski.iextrading4j.api.exception.IEXTradingException; | |
4 | import pl.zankowski.iextrading4j.api.marketdata.Auction; | |
5 | import pl.zankowski.iextrading4j.api.marketdata.Book; | |
6 | import pl.zankowski.iextrading4j.api.marketdata.DeepResult; | |
7 | import pl.zankowski.iextrading4j.api.marketdata.OpHaltStatus; | |
8 | import pl.zankowski.iextrading4j.api.marketdata.SecurityEvent; | |
9 | import pl.zankowski.iextrading4j.api.marketdata.SsrStatus; | |
10 | import pl.zankowski.iextrading4j.api.marketdata.SystemEvent; | |
11 | import pl.zankowski.iextrading4j.api.marketdata.Trade; | |
12 | import pl.zankowski.iextrading4j.api.marketdata.TradingStatus; | |
13 | ||
14 | import java.util.function.Consumer; | |
15 | ||
16 | public class DeepConsumerAdapter implements Consumer<DeepAsyncResponse<DeepResult>> { | |
17 | ||
18 | @Override | |
19 | public final void accept(final DeepAsyncResponse deepAsyncResponse) { | |
20 | final DeepMessageType messageType = deepAsyncResponse.getMessageType(); | |
21 | ||
22 | switch (messageType) { | |
23 | case TRADING_STATUS: | |
24 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptTradingStatus → KILLED |
acceptTradingStatus(deepAsyncResponse); |
25 | break; | |
26 | case AUCTION: | |
27 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptAuction → KILLED |
acceptAuction(deepAsyncResponse); |
28 | break; | |
29 | case OP_HALT_STATUS: | |
30 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptOpHaltStatus → KILLED |
acceptOpHaltStatus(deepAsyncResponse); |
31 | break; | |
32 | case SSR_STATUS: | |
33 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptSsrStatus → KILLED |
acceptSsrStatus(deepAsyncResponse); |
34 | break; | |
35 | case SECURITY_EVENT: | |
36 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptSecurityEvent → KILLED |
acceptSecurityEvent(deepAsyncResponse); |
37 | break; | |
38 | case TRADE_BREAK: | |
39 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptTradeBreak → KILLED |
acceptTradeBreak(deepAsyncResponse); |
40 | break; | |
41 | case TRADES: | |
42 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptTrades → KILLED |
acceptTrades(deepAsyncResponse); |
43 | break; | |
44 | case BOOK: | |
45 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptBook → KILLED |
acceptBook(deepAsyncResponse); |
46 | break; | |
47 | case SYSTEM_EVENT: | |
48 |
1
1. accept : removed call to pl/zankowski/iextrading4j/client/socket/request/marketdata/deep/DeepConsumerAdapter::acceptSystemEvent → KILLED |
acceptSystemEvent(deepAsyncResponse); |
49 | break; | |
50 | default: | |
51 | throw new IEXTradingException("Message type not supported: " + messageType); | |
52 | } | |
53 | } | |
54 | ||
55 | public void acceptTradingStatus(final DeepAsyncResponse<TradingStatus> tradingStatusResponse) { | |
56 | // empty | |
57 | } | |
58 | ||
59 | public void acceptAuction(final DeepAsyncResponse<Auction> auctionResponse) { | |
60 | // empty | |
61 | } | |
62 | ||
63 | public void acceptOpHaltStatus(final DeepAsyncResponse<OpHaltStatus> opHaltStatusResponse) { | |
64 | // empty | |
65 | } | |
66 | ||
67 | public void acceptSsrStatus(final DeepAsyncResponse<SsrStatus> ssrStatusResponse) { | |
68 | // empty | |
69 | } | |
70 | ||
71 | public void acceptSecurityEvent(final DeepAsyncResponse<SecurityEvent> securityEventResponse) { | |
72 | // empty | |
73 | } | |
74 | ||
75 | public void acceptTradeBreak(final DeepAsyncResponse<Trade> tradeBreakResponse) { | |
76 | // empty | |
77 | } | |
78 | ||
79 | public void acceptTrades(final DeepAsyncResponse<Trade> tradesResponse) { | |
80 | // empty | |
81 | } | |
82 | ||
83 | public void acceptBook(final DeepAsyncResponse<Book> bookResponse) { | |
84 | // empty | |
85 | } | |
86 | ||
87 | public void acceptSystemEvent(final DeepAsyncResponse<SystemEvent> systemEventResponse) { | |
88 | // empty | |
89 | } | |
90 | ||
91 | } | |
Mutations | ||
24 |
1.1 |
|
27 |
1.1 |
|
30 |
1.1 |
|
33 |
1.1 |
|
36 |
1.1 |
|
39 |
1.1 |
|
42 |
1.1 |
|
45 |
1.1 |
|
48 |
1.1 |