src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/AsyncEvent.java

*** 1,7 ****
  /*
!  * Copyright (c) 2015, 2016, Oracle and/or its affiliates. All rights reserved.
   * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   *
   * This code is free software; you can redistribute it and/or modify it
   * under the terms of the GNU General Public License version 2 only, as
   * published by the Free Software Foundation.  Oracle designates this
--- 1,7 ----
  /*
!  * Copyright (c) 2015, 2017, Oracle and/or its affiliates. All rights reserved.
   * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   *
   * This code is free software; you can redistribute it and/or modify it
   * under the terms of the GNU General Public License version 2 only, as
   * published by the Free Software Foundation.  Oracle designates this
*** 23,49 ****
   * questions.
   */
  
  package jdk.incubator.http;
  
  import java.nio.channels.SelectableChannel;
  
  /**
   * Event handling interface from HttpClientImpl's selector.
   *
-  * If BLOCKING is set, then the channel will be put in blocking
-  * mode prior to handle() being called. If false, then it remains non-blocking.
-  *
   * If REPEATING is set then the event is not cancelled after being posted.
   */
  abstract class AsyncEvent {
  
-     public static final int BLOCKING = 0x1; // non blocking if not set
      public static final int REPEATING = 0x2; // one off event if not set
  
      protected final int flags;
  
      AsyncEvent(int flags) {
          this.flags = flags;
      }
  
      /** Returns the channel */
--- 23,50 ----
   * questions.
   */
  
  package jdk.incubator.http;
  
+ import java.io.IOException;
  import java.nio.channels.SelectableChannel;
  
  /**
   * Event handling interface from HttpClientImpl's selector.
   *
   * If REPEATING is set then the event is not cancelled after being posted.
   */
  abstract class AsyncEvent {
  
      public static final int REPEATING = 0x2; // one off event if not set
  
      protected final int flags;
  
+     AsyncEvent() {
+         this(0);
+     }
+ 
      AsyncEvent(int flags) {
          this.flags = flags;
      }
  
      /** Returns the channel */
*** 53,68 ****
      public abstract int interestOps();
  
      /** Called when event occurs */
      public abstract void handle();
  
!     /** Called when selector is shutting down. Abort all exchanges. */
!     public abstract void abort();
! 
!     public boolean blocking() {
!         return (flags & BLOCKING) != 0;
!     }
  
      public boolean repeating() {
          return (flags & REPEATING) != 0;
      }
  }
--- 54,70 ----
      public abstract int interestOps();
  
      /** Called when event occurs */
      public abstract void handle();
  
!     /**
!      * Called when an error occurs during registration, or when the selector has
!      * been shut down. Aborts all exchanges.
!      *
!      * @param ioe  the IOException, or null
!      */
!     public abstract void abort(IOException ioe);
  
      public boolean repeating() {
          return (flags & REPEATING) != 0;
      }
  }