(Client client, Object message)
| 1253 | } |
| 1254 | |
| 1255 | public java.util.concurrent.CompletableFuture<Object> pong(Client client, Object message) |
| 1256 | { |
| 1257 | |
| 1258 | return java.util.concurrent.CompletableFuture.supplyAsync(() -> { |
| 1259 | |
| 1260 | // |
| 1261 | // {"op": "ping", "args": ["1761069137485"]} |
| 1262 | // |
| 1263 | Object timeStamp = this.milliseconds(); |
| 1264 | try |
| 1265 | { |
| 1266 | (client.send(new java.util.HashMap<String, Object>() {{ |
| 1267 | put( "args", new java.util.ArrayList<Object>(java.util.Arrays.asList(String.valueOf(timeStamp))) ); |
| 1268 | put( "op", "pong" ); |
| 1269 | }})).join(); |
| 1270 | } catch(Exception e) |
| 1271 | { |
| 1272 | var error = new NetworkError(Helpers.add(Helpers.add(this.id, " handlePing failed with error "), this.exceptionMessage(e))); |
| 1273 | client.reset(error); |
| 1274 | } |
| 1275 | return null; |
| 1276 | }); |
| 1277 | |
| 1278 | } |
| 1279 | |
| 1280 | public Object handlePong(Client client, Object message) |
| 1281 | { |
no test coverage detected