Does this library support auto re connection of Binance websocket when the network connection drops?

[andrewlin0410]

Does this library support auto re connection of Binance websocket when the network connection drops?

[namjug-kim]

@andrewlin0410

it's not best solution, but it will be work

ExchangeClientFactory.websocket(ExchangeVendor.BINANCE)
            .createDepthSnapshot(listOf(CurrencyPair(Currency.BTC, Currency.USDT)))

            // retry when connetion drops
            .doOnTerminate { throw RuntimeException("terminated!") }
            .retryWhen { throwablePublisher ->
                throwablePublisher
                    .doOnNext { log.error(it.message, it) }
                    .flatMap { Mono.delay(Duration.ofSeconds(2)) } // retry wait time
            }

            .doOnNext { /* do something you want */ }

half connection checker(ping/pong handler) not implemented in binance yet. so upper reconnection code is not work with half connection.
but other case it will work fine :).

[andrewlin0410]

while (true) {
            try {

                ExchangeWebsocketClient exchangeWebsocketClient = ExchangeClientFactory.websocket(ExchangeVendor.BINANCE);

                List<CurrencyPair> targetPairs = Collections.singletonList(CurrencyPair.parse("BTC", "USDT"));
                Flux<TickData> tickDataFlux = exchangeWebsocketClient.createTradeWebsocket(targetPairs);
//                .doOnNext(tickData -> System.out.println(tickData.getQuantity()))
//                .subscribe();
                while (true) {
                    TickData tickData = tickDataFlux.blockFirst();
                    System.out.println("time: " + System.currentTimeMillis());
                    System.out.println(tickData.getPrice());
                    System.out.println(tickData.getQuantity());
                    System.out.println("=======================");
                }
            } catch (Exception e) {
                StringWriter stringWriter = new StringWriter();
                    PrintWriter printWriter = new PrintWriter(stringWriter);
                    e.printStackTrace(printWriter);
                    testLogger.info(stringWriter.toString());
                    testLogger.info(e.getMessage());

            }
        }

Would this work? Looks like it does reconnect after wifi disconnection. I just don't know if it will work after 24h. I heard binance would drop connection after 24h?