protected class HTTPConduit.WrappedOutputStream extends AbstractThresholdOutputStream
Modifier and Type | Field and Description |
---|---|
protected CacheAndWriteOutputStream |
cachedStream
This field contains the output stream with which we cache
the request.
|
protected boolean |
cachingForRetransmission
This boolean is true if the request must be cached.
|
protected boolean |
chunking
If we are going to be chunking, we won't flush till close which causes
new chunks, small network packets, etc..
|
protected String |
conduitName |
protected HttpURLConnection |
connection
This field contains the currently active connection.
|
protected Message |
outMessage |
buffer, threshold
wrappedStream, written
Modifier | Constructor and Description |
---|---|
protected |
HTTPConduit.WrappedOutputStream(HTTPConduit.WrappedOutputStream wos) |
protected |
HTTPConduit.WrappedOutputStream(Message outMessage,
HttpURLConnection connection,
boolean possibleRetransmit,
boolean isChunking,
int chunkThreshold,
String conduitName) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Perform any actions required on stream closure (handle response etc.)
|
void |
flush() |
protected void |
handleHeadersTrustCaching() |
protected void |
handleResponse()
This procedure is called on the close of the output stream so
we are ready to handle the response from the connection.
|
protected void |
handleResponseInternal() |
protected void |
handleRetransmits()
This procedure handles all retransmits, if any.
|
protected void |
onFirstWrite()
Perform any actions required on stream flush (freeze headers,
reset output stream ...
|
void |
thresholdNotReached() |
void |
thresholdReached() |
unBuffer, write, write
write
protected HttpURLConnection connection
protected boolean cachingForRetransmission
protected final boolean chunking
protected CacheAndWriteOutputStream cachedStream
protected Message outMessage
protected String conduitName
protected HTTPConduit.WrappedOutputStream(Message outMessage, HttpURLConnection connection, boolean possibleRetransmit, boolean isChunking, int chunkThreshold, String conduitName)
protected HTTPConduit.WrappedOutputStream(HTTPConduit.WrappedOutputStream wos)
public void thresholdNotReached()
thresholdNotReached
in class AbstractThresholdOutputStream
public void thresholdReached()
thresholdReached
in class AbstractThresholdOutputStream
protected void onFirstWrite() throws IOException
onFirstWrite
in class AbstractWrappedOutputStream
IOException
protected void handleHeadersTrustCaching() throws IOException
IOException
public void flush() throws IOException
flush
in interface Flushable
flush
in class AbstractWrappedOutputStream
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class AbstractThresholdOutputStream
IOException
protected void handleRetransmits() throws IOException
IOException
protected void handleResponse() throws IOException
IOException
protected void handleResponseInternal() throws IOException
IOException
Apache CXF