jetty-9 WriteFlusher cleanup

2012-06-06 16:49:27 +02:00 · 2012-06-06 16:49:27 +02:00 · f6643ccbe7
parent 903e4cd0f2
commit f6643ccbe7
1 changed files with 3 additions and 1 deletions
--- a/jetty-io/src/main/java/org/eclipse/jetty/io/WriteFlusher.java
+++ b/jetty-io/src/main/java/org/eclipse/jetty/io/WriteFlusher.java
@ -36,8 +36,10 @@ abstract public class WriteFlusher
    }

    /* ------------------------------------------------------------ */
-    public void write(Object context, Callback callback, ByteBuffer... buffers)
+    public <C> void write(C context, Callback<C> callback, ByteBuffer... buffers)
    {
+        if (callback==null)
+            throw new IllegalArgumentException();
        if (!_writing.compareAndSet(false,true))
            throw new WritePendingException();
        try