public class ProxyCallbackHandler
extends java.lang.Object
Constructor and Description |
---|
ProxyCallbackHandler() |
Modifier and Type | Method and Description |
---|---|
void |
closeRequest(AnonProxyRequest anonRequest)
Signal that the given
AnonProxyRequest is being closed. |
void |
deliverDownstream(AnonProxyRequest anonRequest,
ProxyCallbackBuffer buffer)
Goes through the list of registered
ProxyCallback objects and calls
their handleDownstreamChunk
method with the given request and buffer. |
void |
deliverUpstream(AnonProxyRequest anonRequest,
ProxyCallbackBuffer buffer)
Goes through the list of registered
ProxyCallback objects and calls
their handleUpstreamChunk
method with the given request and buffer. |
void |
registerProxyCallback(ProxyCallback callback) |
void |
removeCallback(ProxyCallback callback) |
public void deliverUpstream(AnonProxyRequest anonRequest, ProxyCallbackBuffer buffer) throws ProxyCallbackNotProcessableException, ProxyCallbackDelayException
ProxyCallback
objects and calls
their handleUpstreamChunk
method with the given request and buffer.anonRequest
- The AnonProxyRequest
the data in the buffer is
coming from.buffer
- The data read from the AnonProxyRequest
ProxyCallbackDelayException
- When more data is needed by a Callback.ProxyCallbackNotProcessableException
- If an error occurred while
processing the data.public void deliverDownstream(AnonProxyRequest anonRequest, ProxyCallbackBuffer buffer) throws ProxyCallbackNotProcessableException, ProxyCallbackDelayException
ProxyCallback
objects and calls
their handleDownstreamChunk
method with the given request and buffer.anonRequest
- The AnonProxyRequest
the data in the buffer is
coming from.buffer
- The data read from the AnonProxyRequest
ProxyCallbackDelayException
- When more data is needed by a Callback.ProxyCallbackNotProcessableException
- If an error occurred while
processing the data.public void closeRequest(AnonProxyRequest anonRequest)
AnonProxyRequest
is being closed.anonRequest
- public void registerProxyCallback(ProxyCallback callback)
public void removeCallback(ProxyCallback callback)
Copyright © 2023. All rights reserved.