What is the best way to get continuous tick data?

[andrewlin0410]

What is the best way to get continuous tick data?

[andrewlin0410]

I have these lines of code I think work pretty well. However, for some reason the onTerminate is reached every few minutes. Can someone tell me what's happening? Is there something wrong with the code?

                        try {
                            Main.waitForNetWork();
                            tradeLogger.info("starting " + coin + "/BTC orderbook upbit");
                            Flux<com.njkim.reactivecrypto.core.common.model.order.OrderBook> orderBookFlux = exchangeWebsocketClient.createDepthSnapshot(Collections.singletonList(com.njkim.reactivecrypto.core.common.model.currency.CurrencyPair.parse(coin, "BTC"))).doOnNext(orderBook -> {
                                try {
                                 //......
                                } catch (Exception e) {
                                    StringWriter stringWriter = new StringWriter();
                                    PrintWriter printWriter = new PrintWriter(stringWriter);
                                    e.printStackTrace(printWriter);
                                    CoinRunnable.tradeLogger.info(stringWriter.toString());
                                } finally {
                                }


                            }).doOnTerminate(() -> {
                                CoinRunnable.tradeLogger.info(coin + "terminated");
                                throw new RuntimeException();
                            }).doOnError(throwable -> {
//                                throw new RuntimeException();
                            });
                            orderBookFlux.blockLast();
                            System.out.println("last reached");
                        } catch (Exception e) {
                            StringWriter stringWriter = new StringWriter();
                            PrintWriter printWriter = new PrintWriter(stringWriter);
                            e.printStackTrace(printWriter);
                            CoinRunnable.tradeLogger.info(stringWriter.toString());
                        }
                    }```