common/src/main/java/HTTPClient/StreamDemultiplexor.java
/**
     * Closes the associated stream. If this one has been markedForClose then
     * the socket is closed; else closeSocketIfAllStreamsClosed is invoked.
     */
Closes the associated stream. If this one has been markedForClose then
the socket is closed; else closeSocketIfAllStreamsClosed is invoked.
Closes the associated stream . If this one has been markedForClose then the socket is closed ; else closeSocketIfAllStreamsClosed is invoked .
private void close(ResponseHandler resph)
    {
	synchronized (RespHandlerList)
	{
	    if (resph != (ResponseHandler) RespHandlerList.getFirst())
		return;
	    Log.write(Log.DEMUX, "Demux: Closing stream " +
				 resph.stream.hashCode());
	    resph.eof = true;
	    RespHandlerList.remove(resph);
	}
	if (resph == MarkedForClose)
	    close(new IOException("Premature end of Keep-Alive"), false);
	else
	    closeSocketIfAllStreamsClosed();
    }
private void close ( ResponseHandler resph ) { synchronized ( RespHandlerList ) { if ( resph != ( ResponseHandler ) RespHandlerList . getFirst ( ) ) return ; Log . write ( Log . DEMUX , "Demux: Closing stream " + resph . stream . hashCode ( ) ) ; resph . eof = true ; RespHandlerList . remove ( resph ) ; } if ( resph == MarkedForClose ) close ( new IOException ( "Premature end of Keep-Alive" ) , false ) ; else closeSocketIfAllStreamsClosed ( ) ; }
Closes the associated stream.
Closes the associated stream .