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

Yannick Lecaillez
20.44.2016 5511a94238385a30b5b516ee360b234ff56d7c3f
opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/LdapResponseMessageWriter.java
@@ -26,10 +26,10 @@
final class LdapResponseMessageWriter implements Subscriber<LdapResponseMessage> {
    private final Connection<?> connection;
    private final Completable.Emitter completable;
    private final Completable.Subscriber completable;
    private Subscription upstream;
    LdapResponseMessageWriter(final Connection<?> connection, final Completable.Emitter completable) {
    LdapResponseMessageWriter(final Connection<?> connection, final Completable.Subscriber completable) {
        this.connection = connection;
        this.completable = completable;
    }
@@ -72,6 +72,6 @@
    @Override
    public void onComplete() {
        completable.complete();
        completable.onComplete();
    }
}