opendj-server-legacy/src/main/java/org/forgerock/opendj/reactive/LDAPClientConnection2.java
@@ -1684,7 +1684,7 @@ } /** Upstream -> BlockingBackpressureSubscription -> Downstream. */ private final class BlockingBackpressureSubscription implements Subscription, Processor<Response, Response> { private static final class BlockingBackpressureSubscription implements Subscription, Processor<Response, Response> { private final AtomicLong pendingRequests = new AtomicLong(); private final AtomicInteger missedDrain = new AtomicInteger(); private final BlockingQueue<Response> queue = new LinkedBlockingQueue<>(32);