730 B
730 B
Нужно также добавить в существующий AppConfig:
public String rpcUrl() { String host = switch (network) { case "devnet" -> "https://devnet.helius-rpc.com/"; case "mainnet" -> "https://mainnet.helius-rpc.com/"; default -> throw new IllegalStateException("Unsupported network: " + network); }; return host + "?api-key=" + heliusApiKey; }
И в HeliusWebSocketClient:
-
Поле: private final CompletableFuture subscribed = new CompletableFuture<>();
-
Метод: public CompletableFuture subscribedFuture() { return subscribed; }
-
В обработчике успешной подписки после лога: subscribed.complete(null);