Class ProxyServlet.DelegatingContentProvider
java.lang.Object
org.eclipse.jetty.util.IteratingCallback
org.eclipse.jetty.proxy.ProxyServlet.DelegatingContentProvider
- All Implemented Interfaces:
EventListener, AsyncContentProvider.Listener, Callback, Invocable
- Enclosing class:
ProxyServlet
private class ProxyServlet.DelegatingContentProvider
extends IteratingCallback
implements AsyncContentProvider.Listener
-
Nested Class Summary
Nested classes/interfaces inherited from class IteratingCallback
IteratingCallback.ActionNested classes/interfaces inherited from interface Callback
Callback.Completable, Callback.Completing, Callback.NestedNested classes/interfaces inherited from interface Invocable
Invocable.InvocationType -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final javax.servlet.http.HttpServletRequestprivate final DeferredContentProviderprivate final Iterator<ByteBuffer> private final Requestprivate final javax.servlet.http.HttpServletResponseFields inherited from interface Invocable
__nonBlocking -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivateDelegatingContentProvider(javax.servlet.http.HttpServletRequest clientRequest, Request proxyRequest, javax.servlet.http.HttpServletResponse proxyResponse, ContentProvider provider, DeferredContentProvider deferred) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidonCompleteFailure(Throwable failure) Invoked when the overall task has completed with a failure.protected voidInvoked when the overall task has completed successfully.voidCallback method invoked when content is availableprotected IteratingCallback.Actionprocess()Method called byIteratingCallback.iterate()to process the asynchronous sub-task.voidMethod to invoke when the asynchronous sub-task succeeds.Methods inherited from class IteratingCallback
close, failed, isClosed, isFailed, isSucceeded, iterate, reset, toString
-
Field Details
-
clientRequest
private final javax.servlet.http.HttpServletRequest clientRequest -
proxyRequest
-
proxyResponse
private final javax.servlet.http.HttpServletResponse proxyResponse -
iterator
-
deferred
-
-
Constructor Details
-
DelegatingContentProvider
private DelegatingContentProvider(javax.servlet.http.HttpServletRequest clientRequest, Request proxyRequest, javax.servlet.http.HttpServletResponse proxyResponse, ContentProvider provider, DeferredContentProvider deferred)
-
-
Method Details
-
process
Description copied from class:IteratingCallbackMethod 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.IDLEwhen no sub tasks are available for execution but the overall job is not completed yetIteratingCallback.Action.SCHEDULEDwhen the sub task asynchronous execution has been startedIteratingCallback.Action.SUCCEEDEDwhen the overall job is completed
- Specified by:
processin classIteratingCallback- Returns:
- the appropriate Action
- Throws:
Exception
-
succeeded
public void succeeded()Description copied from class:IteratingCallbackMethod to invoke when the asynchronous sub-task succeeds.Subclasses that override this method must always remember to call
super.succeeded().- Specified by:
succeededin interfaceCallback- Overrides:
succeededin classIteratingCallback- See Also:
-
onCompleteSuccess
protected void onCompleteSuccess()Description copied from class:IteratingCallbackInvoked when the overall task has completed successfully.- Overrides:
onCompleteSuccessin classIteratingCallback- See Also:
-
onCompleteFailure
Description copied from class:IteratingCallbackInvoked when the overall task has completed with a failure.- Overrides:
onCompleteFailurein classIteratingCallback- Parameters:
failure- the throwable to indicate cause of failure- See Also:
-
getInvocationType
- Specified by:
getInvocationTypein interfaceInvocable- Returns:
- The InvocationType of this object
-
onContent
public void onContent()Description copied from interface:AsyncContentProvider.ListenerCallback method invoked when content is available- Specified by:
onContentin interfaceAsyncContentProvider.Listener
-