< 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 >