< prev index next >
src/java.net.http/share/classes/jdk/internal/net/http/SocketTube.java
Print this page
*** 320,330 ****
// Don't use a SequentialScheduler here: rely on onNext() being invoked
// sequentially, and not being invoked if there is no demand, request(1).
// onNext is usually called from within a user / executor thread.
// Initial writing will be performed in that thread. If for some reason,
// not all the data can be written, a writeEvent will be registered, and
! // writing will resume in the the selector manager thread when the
// writeEvent is fired.
//
// If this method is invoked in the selector manager thread (because of
// a writeEvent), then the executor will be used to invoke request(1),
// ensuring that onNext() won't be invoked from within the selector
--- 320,330 ----
// Don't use a SequentialScheduler here: rely on onNext() being invoked
// sequentially, and not being invoked if there is no demand, request(1).
// onNext is usually called from within a user / executor thread.
// Initial writing will be performed in that thread. If for some reason,
// not all the data can be written, a writeEvent will be registered, and
! // writing will resume in the selector manager thread when the
// writeEvent is fired.
//
// If this method is invoked in the selector manager thread (because of
// a writeEvent), then the executor will be used to invoke request(1),
// ensuring that onNext() won't be invoked from within the selector
< prev index next >