Fix from review

use the new close(Throwable) in endpoint
2019-02-17 18:11:23 +09:00 · 2019-02-17 18:11:23 +09:00 · a4a6bd03e7
parent 3d096c9e99
commit a4a6bd03e7
1 changed files with 1 additions and 4 deletions
--- a/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/core/internal/FrameFlusher.java
+++ b/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/core/internal/FrameFlusher.java
@ -263,10 +263,7 @@ public class FrameFlusher extends IteratingCallback
            entry.release();
        }
        entries.clear();
-        if (endPoint instanceof AbstractEndPoint)
-            ((AbstractEndPoint)endPoint).close(failure);
-        else
-            endPoint.close();
+        endPoint.close(failure);
    }

    private void releaseAggregate()