mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

Matthew Swift
10.19.2016 1ad3e7a6cb2b455c4f230e4b5defc14b931583f4
Minor fix: let the result handler complete the request processing

Without this fix the example Proxy never returns responses to the client
application causing the client to hang indefinitely.

The proxy is asynchronous, so the client side response handler (emitter)
must be completed on completion of the proxied request. Before this
change the proxy would forward the request, then complete the response
handler, and only later receive the response to the proxied operation.
When it then tried to forward the results to the client it would
discover that the client's request had been cancelled.
1 files modified
1 ■■■■ changed files
opendj-core/src/main/java/com/forgerock/reactive/ServerConnectionFactoryAdapter.java 1 ●●●● patch | view | raw | blame | history
opendj-core/src/main/java/com/forgerock/reactive/ServerConnectionFactoryAdapter.java
@@ -211,7 +211,6 @@
                            // Unbind request are received through ConnectionEventListener only
                        }
                    });
                    emitter.onComplete();
                }
            }, BackpressureStrategy.ERROR));
        }