Package org.apache.hc.core5.http.impl.nio

Class ServerHttp1StreamDuplexer.DelayedOutputChannel

java.lang.Object

org.apache.hc.core5.http.impl.nio.ServerHttp1StreamDuplexer.DelayedOutputChannel

All Implemented Interfaces:

Http1StreamChannel<HttpResponse>, ContentEncoder

Enclosing class:

ServerHttp1StreamDuplexer

private static class ServerHttp1StreamDuplexer.DelayedOutputChannel
extends Object
implements Http1StreamChannel<HttpResponse>

Field Summary

Fields

Modifier and Type	Field	Description
private final Http1StreamChannel<HttpResponse>	channel
private boolean	completed
private HttpResponse	delayedResponse
private boolean	direct

Constructor Summary

Constructors

Modifier	Constructor	Description
private	DelayedOutputChannel(Http1StreamChannel<HttpResponse> channel)

Method Summary

Modifier and Type	Method	Description
boolean	abortGracefully()
void	activate()
void	close()
void	complete(List<? extends Header> trailers)	Terminates the content stream.
Timeout	getSocketTimeout()
boolean	isCompleted()	Returns true if the entity has been transferred in its entirety.
void	requestOutput()
void	setSocketTimeout(Timeout timeout)
void	submit(HttpResponse response, boolean endStream, FlushMode flushMode)
void	suspendOutput()
int	write(ByteBuffer src)	Writes a portion of entity content to the underlying channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

channel

private final Http1StreamChannel<HttpResponse> channel

direct

private volatile boolean direct

delayedResponse

private volatile HttpResponse delayedResponse

completed

private volatile boolean completed

Constructor Details

DelayedOutputChannel

private DelayedOutputChannel(Http1StreamChannel<HttpResponse> channel)

Method Details

close

public void close()

Specified by:

close in interface Http1StreamChannel<HttpResponse>

submit

public void submit(HttpResponse response,
 boolean endStream,
 FlushMode flushMode)
            throws HttpException,
IOException

Specified by:

submit in interface Http1StreamChannel<HttpResponse>

Throws:

HttpException

IOException

suspendOutput

public void suspendOutput()
                   throws IOException

Specified by:

suspendOutput in interface Http1StreamChannel<HttpResponse>

Throws:

IOException

requestOutput

public void requestOutput()

Specified by:

requestOutput in interface Http1StreamChannel<HttpResponse>

getSocketTimeout

public Timeout getSocketTimeout()

Specified by:

getSocketTimeout in interface Http1StreamChannel<HttpResponse>

setSocketTimeout

public void setSocketTimeout(Timeout timeout)

Specified by:

setSocketTimeout in interface Http1StreamChannel<HttpResponse>

write

public int write(ByteBuffer src)
          throws IOException

Description copied from interface: ContentEncoder

Writes a portion of entity content to the underlying channel.

Specified by:

write in interface ContentEncoder

Parameters:

src - The buffer from which content is to be retrieved

Returns:

The number of bytes read, possibly zero

Throws:

IOException - if I/O error occurs while writing content

complete

public void complete(List<? extends Header> trailers)
              throws IOException

Description copied from interface: ContentEncoder

Terminates the content stream.

Specified by:

complete in interface ContentEncoder

Throws:

IOException - if I/O error occurs while writing content

abortGracefully

public boolean abortGracefully()
                        throws IOException

Specified by:

abortGracefully in interface Http1StreamChannel<HttpResponse>

Throws:

IOException

isCompleted

public boolean isCompleted()

Description copied from interface: ContentEncoder

Returns true if the entity has been transferred in its entirety.

Specified by:

isCompleted in interface ContentEncoder

Returns:

true if all the content has been produced, false otherwise.

activate

public void activate()
              throws IOException,
HttpException

Specified by:

activate in interface Http1StreamChannel<HttpResponse>

Throws:

IOException

HttpException