From 5511a94238385a30b5b516ee360b234ff56d7c3f Mon Sep 17 00:00:00 2001
From: Yannick Lecaillez <yannick.lecaillez@forgerock.com>
Date: Mon, 07 Nov 2016 13:59:40 +0000
Subject: [PATCH] OPENDJ-3179: Migrate LDAP Connection Handler to SDK Grizzly transport
---
opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/LdapResponseMessageWriter.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/LdapResponseMessageWriter.java b/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/LdapResponseMessageWriter.java
index 9e3fa30..007ce33 100644
--- a/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/LdapResponseMessageWriter.java
+++ b/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();
}
}
--
Gitblit v1.10.0