xchange-stream library has memory leak issue on exchange disconnect

[pchertalev]

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]

ExchangeSpecification is empty so only public socket is created

[pchertalev]

Issue is reproduced for public socket and private socket - it is core bitrich functionality

[mdvx]

good catch and fix

[pchertalev]

Thanks. Close issue