equal
deleted
inserted
replaced
303 } |
303 } |
304 } |
304 } |
305 |
305 |
306 @Override |
306 @Override |
307 public void onNext(List<ByteBuffer> bufs) { |
307 public void onNext(List<ByteBuffer> bufs) { |
308 assert current == null; // this is a queue of 1. |
308 assert current == null : dbgString() // this is a queue of 1. |
309 assert subscription != null; |
309 + "w.onNext current: " + current; |
|
310 assert subscription != null : dbgString() |
|
311 + "w.onNext: subscription is null"; |
310 current = bufs; |
312 current = bufs; |
311 tryFlushCurrent(client.isSelectorThread()); // may be in selector thread |
313 tryFlushCurrent(client.isSelectorThread()); // may be in selector thread |
312 // For instance in HTTP/2, a received SETTINGS frame might trigger |
314 // For instance in HTTP/2, a received SETTINGS frame might trigger |
313 // the sending of a SETTINGS frame in turn which might cause |
315 // the sending of a SETTINGS frame in turn which might cause |
314 // onNext to be called from within the same selector thread that the |
316 // onNext to be called from within the same selector thread that the |