394854 Implemented Promise

1 files changed, 5 insertions, 5 deletions

diff --git a/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java b/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java
index 06fe0beb09..b6806b703b 100644
--- a/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java
+++ b/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java
@@ -413,16 +413,16 @@ public class HttpConnection extends AbstractConnection implements Runnable, Http
     }
 
     @Override
-    public <C> void send(ResponseInfo info, ByteBuffer content, boolean lastContent, C context, Callback<C> callback)
+    public void send(ResponseInfo info, ByteBuffer content, boolean lastContent, Callback callback)
     {
         try
         {
             send(info,content,lastContent);
-            callback.completed(context);
+            callback.succeeded();
         }
         catch (IOException e)
         {
-            callback.failed(context,e);
+            callback.failed(e);
         }
     }
 
@@ -430,7 +430,7 @@ public class HttpConnection extends AbstractConnection implements Runnable, Http
     {
         try
         {
-            getEndPoint().write(_writeBlocker.getPhase(), _writeBlocker, bytes);
+            getEndPoint().write(_writeBlocker, bytes);
             _writeBlocker.block();
         }
         catch (InterruptedException x)
@@ -557,7 +557,7 @@ public class HttpConnection extends AbstractConnection implements Runnable, Http
                         }
 
                         // Wait until we can read
-                        getEndPoint().fillInterested(_readBlocker.getPhase(),_readBlocker);
+                        getEndPoint().fillInterested(_readBlocker);
                         LOG.debug("{} block readable on {}",this,_readBlocker);
                         _readBlocker.block();