xchange-stream library has memory leak issue on exchange disconnect
Closed this issue · 4 comments
pchertalev commented
How to reproduce:
ExchangeSpecification exchangeSpecification = new ExchangeSpecification(KrakenStreamingExchange.class);
for (;;) {
StreamingExchange krakenExchange = StreamingExchangeFactory.INSTANCE.createExchange(exchangeSpecification);
krakenExchange.connect().blockingAwait();
krakenExchange.disconnect().subscribe(() -> LOG.info("Disconnected"));
}
mdvx commented
ExchangeSpecification is empty so only public socket is created
pchertalev commented
Issue is reproduced for public socket and private socket - it is core bitrich functionality
mdvx commented
good catch and fix
pchertalev commented
Thanks. Close issue