Class AsyncProxyServlet.StreamReader
- All Implemented Interfaces:
jakarta.servlet.ReadListener
,EventListener
,Callback
,Invocable
- Enclosing class:
AsyncProxyServlet
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.jetty.util.IteratingCallback
IteratingCallback.Action
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback
Callback.Combination, Callback.Completable, Callback.Completing, Callback.Nested
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable
Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task
-
Field Summary
Fields inherited from interface org.eclipse.jetty.util.Callback
NOOP, NOT_CALLED
Fields inherited from interface org.eclipse.jetty.util.thread.Invocable
__nonBlocking
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
StreamReader
(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response, Request proxyRequest, AsyncRequestContent content) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
void
protected void
protected void
onRequestContent
(jakarta.servlet.http.HttpServletRequest request, Request proxyRequest, AsyncRequestContent content, byte[] buffer, int offset, int length, Callback callback) protected IteratingCallback.Action
process()
Method called byIteratingCallback.iterate()
to process the asynchronous sub-task.Methods inherited from class org.eclipse.jetty.util.IteratingCallback
abort, close, failed, isAborted, isClosed, isFailed, isSucceeded, iterate, onAborted, onCompleted, onCompleteFailure, onCompleteSuccess, onSuccess, reset, succeeded, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.eclipse.jetty.util.Callback
completeWith
Methods inherited from interface org.eclipse.jetty.util.thread.Invocable
getInvocationType
-
Constructor Details
-
StreamReader
protected StreamReader(jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response, Request proxyRequest, AsyncRequestContent content)
-
-
Method Details
-
onDataAvailable
public void onDataAvailable()- Specified by:
onDataAvailable
in interfacejakarta.servlet.ReadListener
-
onAllDataRead
public void onAllDataRead()- Specified by:
onAllDataRead
in interfacejakarta.servlet.ReadListener
-
onError
- Specified by:
onError
in interfacejakarta.servlet.ReadListener
-
process
Description copied from class:IteratingCallback
Method called byIteratingCallback.iterate()
to process the asynchronous sub-task.Implementations must initiate the asynchronous execution of the sub-task (if any) and return an appropriate action:
IteratingCallback.Action.IDLE
when no sub tasks are available for execution but the overall job is not completed yetIteratingCallback.Action.SCHEDULED
when the sub task asynchronous execution has been startedIteratingCallback.Action.SUCCEEDED
when the overall job is completed
- Specified by:
process
in classIteratingCallback
- Returns:
- the appropriate Action
- Throws:
Exception
-
onRequestContent
protected void onRequestContent(jakarta.servlet.http.HttpServletRequest request, Request proxyRequest, AsyncRequestContent content, byte[] buffer, int offset, int length, Callback callback) -
onFailure
Description copied from class:IteratingCallback
Invoked when the overall task has beenaborted
orfailed
.Calls to this method are serialized with respect to
IteratingCallback.onAborted(Throwable)
,IteratingCallback.process()
,IteratingCallback.onCompleteFailure(Throwable)
andIteratingCallback.onCompleted(Throwable)
.Because
onFailure
can be called due to anIteratingCallback.abort(Throwable)
orIteratingCallback.close()
operation, it is possible that any resources passed to aIteratingCallback.Action.SCHEDULED
operation may still be in use, and thus should not be recycled by this call. For example any buffers passed to a write operation should not be returned to a buffer pool by implementations ofonFailure
. Such resources may be discarded here, or safely recycled in a subsequent call toIteratingCallback.onCompleted(Throwable)
orIteratingCallback.onCompleteFailure(Throwable)
, when theIteratingCallback.Action.SCHEDULED
operation has completed.- Overrides:
onFailure
in classIteratingCallback
- Parameters:
x
- The cause of the failure or abort- See Also:
-