MCPcopy Index your code
hub / github.com/ccxt/ccxt / pong

Method pong

java/lib/src/main/java/io/github/ccxt/exchanges/pro/HtxCore.java:2581–2626  ·  view source on GitHub ↗
(Client client, Object message)

Source from the content-addressed store, hash-verified

2579 }
2580
2581 public java.util.concurrent.CompletableFuture<Object> pong(Client client, Object message)
2582 {
2583
2584 return java.util.concurrent.CompletableFuture.supplyAsync(() -> {
2585
2586 try
2587 {
2588 Object ping = this.safeInteger(message, "ping");
2589 if (Helpers.isTrue(!Helpers.isEqual(ping, null)))
2590 {
2591 (client.send(new java.util.HashMap<String, Object>() {{
2592 put( "pong", ping );
2593 }})).join();
2594 return null;
2595 }
2596 Object action = this.safeString(message, "action");
2597 if (Helpers.isTrue(Helpers.isEqual(action, "ping")))
2598 {
2599 Object data = this.safeValue(message, "data");
2600 Object pingTs = this.safeInteger(data, "ts");
2601 (client.send(new java.util.HashMap<String, Object>() {{
2602 put( "action", "pong" );
2603 put( "data", new java.util.HashMap<String, Object>() {{
2604 put( "ts", pingTs );
2605 }} );
2606 }})).join();
2607 return null;
2608 }
2609 Object op = this.safeString(message, "op");
2610 if (Helpers.isTrue(Helpers.isEqual(op, "ping")))
2611 {
2612 Object pingTs = this.safeInteger(message, "ts");
2613 (client.send(new java.util.HashMap<String, Object>() {{
2614 put( "op", "pong" );
2615 put( "ts", pingTs );
2616 }})).join();
2617 }
2618 } catch(Exception e)
2619 {
2620 var error = new NetworkError(Helpers.add(Helpers.add(this.id, " pong failed "), this.exceptionMessage(e)));
2621 client.reset(error);
2622 }
2623 return null;
2624 });
2625
2626 }
2627
2628 public void handlePing(Client client, Object message)
2629 {

Callers 1

handlePingMethod · 0.95

Calls 9

isTrueMethod · 0.95
isEqualMethod · 0.95
addMethod · 0.95
safeIntegerMethod · 0.45
sendMethod · 0.45
safeStringMethod · 0.45
safeValueMethod · 0.45
exceptionMessageMethod · 0.45
resetMethod · 0.45

Tested by

no test coverage detected