--- a/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/Http2Connection.java	Wed Jan 24 12:26:15 2018 +0000
+++ b/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/Http2Connection.java	Fri Jan 26 11:08:42 2018 +0000
@@ -1088,7 +1088,7 @@
             debug.log(Level.DEBUG, () -> "onNext: got " + Utils.remaining(item)
                     + " bytes in " + item.size() + " buffers");
             queue.addAll(item);
-            scheduler.deferOrSchedule(client().theExecutor());
+            scheduler.runOrSchedule(client().theExecutor());
         }
 
         @Override
@@ -1096,7 +1096,7 @@
             debug.log(Level.DEBUG, () -> "onError: " + throwable);
             error = throwable;
             completed = true;
-            scheduler.deferOrSchedule(client().theExecutor());
+            scheduler.runOrSchedule(client().theExecutor());
         }
 
         @Override
@@ -1104,7 +1104,7 @@
             debug.log(Level.DEBUG, "EOF");
             error = new EOFException("EOF reached while reading");
             completed = true;
-            scheduler.deferOrSchedule(client().theExecutor());
+            scheduler.runOrSchedule(client().theExecutor());
         }
 
         @Override