Closed newnius closed 5 years ago
Replace
closer.register(new Closeable() { @Override public void close() throws IOException { context.releaseBlockWorkerClient(address, blockWorker); } });
with
closer.register(() -> context.releaseBlockWorkerClient(address, blockWorker));
Replace
with