hc-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ol...@apache.org
Subject svn commit: r1711465 [14/34] - in /httpcomponents/site/httpcomponents-core-4.4.x: ./ httpcore-ab/ httpcore-nio/ httpcore-nio/apidocs/ httpcore-nio/apidocs/org/apache/http/impl/nio/ httpcore-nio/apidocs/org/apache/http/impl/nio/bootstrap/ httpcore-nio/a...
Date Fri, 30 Oct 2015 13:06:04 GMT
Modified: httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref-test/org/apache/http/nio/protocol/TestHttpAsyncService.html
URL: http://svn.apache.org/viewvc/httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref-test/org/apache/http/nio/protocol/TestHttpAsyncService.html?rev=1711465&r1=1711464&r2=1711465&view=diff
==============================================================================
--- httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref-test/org/apache/http/nio/protocol/TestHttpAsyncService.html (original)
+++ httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref-test/org/apache/http/nio/protocol/TestHttpAsyncService.html Fri Oct 30 13:05:47 2015
@@ -837,555 +837,554 @@
 <a class="jxr_linenumber" name="827" href="#827">827</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
 <a class="jxr_linenumber" name="828" href="#828">828</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).responseCompleted(exchangeContext);
 <a class="jxr_linenumber" name="829" href="#829">829</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).requestInput();
-<a class="jxr_linenumber" name="830" href="#830">830</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).suspendOutput();
-<a class="jxr_linenumber" name="831" href="#831">831</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
-<a class="jxr_linenumber" name="832" href="#832">832</a>     }
-<a class="jxr_linenumber" name="833" href="#833">833</a> 
-<a class="jxr_linenumber" name="834" href="#834">834</a>     @Test
-<a class="jxr_linenumber" name="835" href="#835">835</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testBasicResponseWithPipelining() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="836" href="#836">836</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="837" href="#837">837</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="838" href="#838">838</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="839" href="#839">839</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="840" href="#840">840</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="841" href="#841">841</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="842" href="#842">842</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="843" href="#843">843</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="844" href="#844">844</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="845" href="#845">845</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="846" href="#846">846</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="847" href="#847">847</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="848" href="#848">848</a> 
-<a class="jxr_linenumber" name="849" href="#849">849</a>         <strong class="jxr_keyword">final</strong> Queue&lt;PipelineEntry&gt; pipeline = state.getPipeline();
-<a class="jxr_linenumber" name="850" href="#850">850</a> 
-<a class="jxr_linenumber" name="851" href="#851">851</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext2 = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="852" href="#852">852</a>         <strong class="jxr_keyword">final</strong> HttpRequest pipelinedRequest = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="853" href="#853">853</a>         <strong class="jxr_keyword">final</strong> PipelineEntry entry = <strong class="jxr_keyword">new</strong> PipelineEntry(pipelinedRequest, pipelinedRequest,
-<a class="jxr_linenumber" name="854" href="#854">854</a>                 <strong class="jxr_keyword">null</strong>, requestHandler, exchangeContext2);
-<a class="jxr_linenumber" name="855" href="#855">855</a>         pipeline.add(entry);
-<a class="jxr_linenumber" name="856" href="#856">856</a> 
-<a class="jxr_linenumber" name="857" href="#857">857</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="858" href="#858">858</a> 
-<a class="jxr_linenumber" name="859" href="#859">859</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="860" href="#860">860</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.TRUE);
-<a class="jxr_linenumber" name="861" href="#861">861</a> 
-<a class="jxr_linenumber" name="862" href="#862">862</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="863" href="#863">863</a> 
-<a class="jxr_linenumber" name="864" href="#864">864</a>         Assert.assertEquals(MessageState.BODY_STREAM, state.getResponseState());
-<a class="jxr_linenumber" name="865" href="#865">865</a> 
-<a class="jxr_linenumber" name="866" href="#866">866</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.httpProcessor).process(response, exchangeContext);
-<a class="jxr_linenumber" name="867" href="#867">867</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).suspendOutput();
-<a class="jxr_linenumber" name="868" href="#868">868</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
-<a class="jxr_linenumber" name="869" href="#869">869</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
-<a class="jxr_linenumber" name="870" href="#870">870</a>     }
-<a class="jxr_linenumber" name="871" href="#871">871</a> 
-<a class="jxr_linenumber" name="872" href="#872">872</a>     @Test
-<a class="jxr_linenumber" name="873" href="#873">873</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testBasicResponseNoKeepAlive() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="874" href="#874">874</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="875" href="#875">875</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="876" href="#876">876</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="877" href="#877">877</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="878" href="#878">878</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="879" href="#879">879</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="880" href="#880">880</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="881" href="#881">881</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="882" href="#882">882</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="883" href="#883">883</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="884" href="#884">884</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="885" href="#885">885</a>         state.setResponseState(MessageState.INIT);
-<a class="jxr_linenumber" name="886" href="#886">886</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="887" href="#887">887</a> 
-<a class="jxr_linenumber" name="888" href="#888">888</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="889" href="#889">889</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.FALSE);
-<a class="jxr_linenumber" name="890" href="#890">890</a> 
-<a class="jxr_linenumber" name="891" href="#891">891</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="892" href="#892">892</a> 
-<a class="jxr_linenumber" name="893" href="#893">893</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="894" href="#894">894</a> 
-<a class="jxr_linenumber" name="895" href="#895">895</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.httpProcessor).process(response, exchangeContext);
-<a class="jxr_linenumber" name="896" href="#896">896</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
-<a class="jxr_linenumber" name="897" href="#897">897</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).responseCompleted(exchangeContext);
-<a class="jxr_linenumber" name="898" href="#898">898</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).close();
-<a class="jxr_linenumber" name="899" href="#899">899</a>     }
-<a class="jxr_linenumber" name="900" href="#900">900</a> 
-<a class="jxr_linenumber" name="901" href="#901">901</a>     @Test
-<a class="jxr_linenumber" name="902" href="#902">902</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testEntityEnclosingResponse() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="903" href="#903">903</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="904" href="#904">904</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="905" href="#905">905</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="906" href="#906">906</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="907" href="#907">907</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="908" href="#908">908</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="909" href="#909">909</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="910" href="#910">910</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="911" href="#911">911</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="912" href="#912">912</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="913" href="#913">913</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="914" href="#914">914</a>         state.setResponseState(MessageState.INIT);
-<a class="jxr_linenumber" name="915" href="#915">915</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="916" href="#916">916</a> 
-<a class="jxr_linenumber" name="917" href="#917">917</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="918" href="#918">918</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="919" href="#919">919</a> 
-<a class="jxr_linenumber" name="920" href="#920">920</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="921" href="#921">921</a> 
-<a class="jxr_linenumber" name="922" href="#922">922</a>         Assert.assertEquals(MessageState.COMPLETED, state.getRequestState());
-<a class="jxr_linenumber" name="923" href="#923">923</a>         Assert.assertEquals(MessageState.BODY_STREAM, state.getResponseState());
-<a class="jxr_linenumber" name="924" href="#924">924</a>         Assert.assertEquals(<span class="jxr_string">"[incoming COMPLETED GET / HTTP/1.1; outgoing BODY_STREAM HTTP/1.1 200 OK]"</span>,
-<a class="jxr_linenumber" name="925" href="#925">925</a>                 state.toString());
-<a class="jxr_linenumber" name="926" href="#926">926</a> 
-<a class="jxr_linenumber" name="927" href="#927">927</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.httpProcessor).process(response, exchangeContext);
-<a class="jxr_linenumber" name="928" href="#928">928</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
-<a class="jxr_linenumber" name="929" href="#929">929</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer, Mockito.never()).responseCompleted(exchangeContext);
-<a class="jxr_linenumber" name="930" href="#930">930</a>     }
-<a class="jxr_linenumber" name="931" href="#931">931</a> 
-<a class="jxr_linenumber" name="932" href="#932">932</a>     @Test
-<a class="jxr_linenumber" name="933" href="#933">933</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseToHead() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="934" href="#934">934</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="935" href="#935">935</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="936" href="#936">936</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"HEAD"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="937" href="#937">937</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="938" href="#938">938</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="939" href="#939">939</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="940" href="#940">940</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="941" href="#941">941</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="942" href="#942">942</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="943" href="#943">943</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="944" href="#944">944</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="945" href="#945">945</a>         state.setResponseState(MessageState.INIT);
-<a class="jxr_linenumber" name="946" href="#946">946</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="947" href="#947">947</a> 
-<a class="jxr_linenumber" name="948" href="#948">948</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="949" href="#949">949</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="950" href="#950">950</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.TRUE);
-<a class="jxr_linenumber" name="951" href="#951">951</a> 
-<a class="jxr_linenumber" name="952" href="#952">952</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="953" href="#953">953</a> 
-<a class="jxr_linenumber" name="954" href="#954">954</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="955" href="#955">955</a> 
-<a class="jxr_linenumber" name="956" href="#956">956</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.httpProcessor).process(response, exchangeContext);
-<a class="jxr_linenumber" name="957" href="#957">957</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
-<a class="jxr_linenumber" name="958" href="#958">958</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).responseCompleted(exchangeContext);
-<a class="jxr_linenumber" name="959" href="#959">959</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).requestInput();
-<a class="jxr_linenumber" name="960" href="#960">960</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
-<a class="jxr_linenumber" name="961" href="#961">961</a>     }
-<a class="jxr_linenumber" name="962" href="#962">962</a> 
-<a class="jxr_linenumber" name="963" href="#963">963</a>     @Test
-<a class="jxr_linenumber" name="964" href="#964">964</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseNotModified() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="965" href="#965">965</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="966" href="#966">966</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="967" href="#967">967</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"HEAD"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="968" href="#968">968</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="969" href="#969">969</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="970" href="#970">970</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="971" href="#971">971</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="972" href="#972">972</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1,
-<a class="jxr_linenumber" name="973" href="#973">973</a>                 HttpStatus.SC_NOT_MODIFIED, <span class="jxr_string">"Not modified"</span>);
-<a class="jxr_linenumber" name="974" href="#974">974</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="975" href="#975">975</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="976" href="#976">976</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="977" href="#977">977</a>         state.setResponseState(MessageState.INIT);
-<a class="jxr_linenumber" name="978" href="#978">978</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="979" href="#979">979</a> 
-<a class="jxr_linenumber" name="980" href="#980">980</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="981" href="#981">981</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="982" href="#982">982</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.TRUE);
-<a class="jxr_linenumber" name="983" href="#983">983</a> 
-<a class="jxr_linenumber" name="984" href="#984">984</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="985" href="#985">985</a> 
-<a class="jxr_linenumber" name="986" href="#986">986</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="987" href="#987">987</a> 
-<a class="jxr_linenumber" name="988" href="#988">988</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.httpProcessor).process(response, exchangeContext);
-<a class="jxr_linenumber" name="989" href="#989">989</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
-<a class="jxr_linenumber" name="990" href="#990">990</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).responseCompleted(exchangeContext);
-<a class="jxr_linenumber" name="991" href="#991">991</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).requestInput();
-<a class="jxr_linenumber" name="992" href="#992">992</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
-<a class="jxr_linenumber" name="993" href="#993">993</a>     }
-<a class="jxr_linenumber" name="994" href="#994">994</a> 
-<a class="jxr_linenumber" name="995" href="#995">995</a>     @Test
-<a class="jxr_linenumber" name="996" href="#996">996</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseContinue() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="997" href="#997">997</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="998" href="#998">998</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="999" href="#999">999</a>         <strong class="jxr_keyword">final</strong> HttpEntityEnclosingRequest request = <strong class="jxr_keyword">new</strong> BasicHttpEntityEnclosingRequest(<span class="jxr_string">"POST"</span>, <span class="jxr_string">"/"</span>,
-<a class="jxr_linenumber" name="1000" href="#1000">1000</a>                 HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1001" href="#1001">1001</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="1002" href="#1002">1002</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="1003" href="#1003">1003</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="1004" href="#1004">1004</a>         state.setRequestState(MessageState.ACK_EXPECTED);
-<a class="jxr_linenumber" name="1005" href="#1005">1005</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1,
-<a class="jxr_linenumber" name="1006" href="#1006">1006</a>                 HttpStatus.SC_CONTINUE, <span class="jxr_string">"Continue"</span>);
-<a class="jxr_linenumber" name="1007" href="#1007">1007</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1008" href="#1008">1008</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1009" href="#1009">1009</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1010" href="#1010">1010</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1011" href="#1011">1011</a> 
-<a class="jxr_linenumber" name="1012" href="#1012">1012</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="1013" href="#1013">1013</a> 
-<a class="jxr_linenumber" name="1014" href="#1014">1014</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1015" href="#1015">1015</a> 
-<a class="jxr_linenumber" name="1016" href="#1016">1016</a>         Assert.assertEquals(MessageState.BODY_STREAM, state.getRequestState());
-<a class="jxr_linenumber" name="1017" href="#1017">1017</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="1018" href="#1018">1018</a> 
-<a class="jxr_linenumber" name="1019" href="#1019">1019</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).requestInput();
-<a class="jxr_linenumber" name="1020" href="#1020">1020</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(Mockito.argThat(<strong class="jxr_keyword">new</strong> ArgumentMatcher&lt;HttpResponse&gt;() {
-<a class="jxr_linenumber" name="1021" href="#1021">1021</a> 
-<a class="jxr_linenumber" name="1022" href="#1022">1022</a>             @Override
-<a class="jxr_linenumber" name="1023" href="#1023">1023</a>             <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">boolean</strong> matches(<strong class="jxr_keyword">final</strong> Object argument) {
-<a class="jxr_linenumber" name="1024" href="#1024">1024</a>                 <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> status = ((HttpResponse) argument).getStatusLine().getStatusCode();
-<a class="jxr_linenumber" name="1025" href="#1025">1025</a>                 <strong class="jxr_keyword">return</strong> status == 100;
-<a class="jxr_linenumber" name="1026" href="#1026">1026</a>             }
-<a class="jxr_linenumber" name="1027" href="#1027">1027</a> 
-<a class="jxr_linenumber" name="1028" href="#1028">1028</a>         }));
-<a class="jxr_linenumber" name="1029" href="#1029">1029</a>     }
-<a class="jxr_linenumber" name="1030" href="#1030">1030</a> 
-<a class="jxr_linenumber" name="1031" href="#1031">1031</a>     @Test
-<a class="jxr_linenumber" name="1032" href="#1032">1032</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseFailedExpectation() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1033" href="#1033">1033</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1034" href="#1034">1034</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1035" href="#1035">1035</a>         <strong class="jxr_keyword">final</strong> HttpEntityEnclosingRequest request = <strong class="jxr_keyword">new</strong> BasicHttpEntityEnclosingRequest(<span class="jxr_string">"POST"</span>, <span class="jxr_string">"/"</span>,
-<a class="jxr_linenumber" name="1036" href="#1036">1036</a>                 HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1037" href="#1037">1037</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="1038" href="#1038">1038</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="1039" href="#1039">1039</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="1040" href="#1040">1040</a>         state.setRequestState(MessageState.ACK_EXPECTED);
-<a class="jxr_linenumber" name="1041" href="#1041">1041</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1,
-<a class="jxr_linenumber" name="1042" href="#1042">1042</a>                 417, <span class="jxr_string">"Expectation failed"</span>);
-<a class="jxr_linenumber" name="1043" href="#1043">1043</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1044" href="#1044">1044</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1045" href="#1045">1045</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1046" href="#1046">1046</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1047" href="#1047">1047</a> 
-<a class="jxr_linenumber" name="1048" href="#1048">1048</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="1049" href="#1049">1049</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="1050" href="#1050">1050</a> 
-<a class="jxr_linenumber" name="1051" href="#1051">1051</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1052" href="#1052">1052</a> 
-<a class="jxr_linenumber" name="1053" href="#1053">1053</a>         Assert.assertEquals(MessageState.READY, state.getRequestState());
-<a class="jxr_linenumber" name="1054" href="#1054">1054</a>         Assert.assertEquals(MessageState.BODY_STREAM, state.getResponseState());
-<a class="jxr_linenumber" name="1055" href="#1055">1055</a> 
-<a class="jxr_linenumber" name="1056" href="#1056">1056</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).resetInput();
-<a class="jxr_linenumber" name="1057" href="#1057">1057</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.httpProcessor).process(response, exchangeContext);
-<a class="jxr_linenumber" name="1058" href="#1058">1058</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
-<a class="jxr_linenumber" name="1059" href="#1059">1059</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer, Mockito.never()).responseCompleted(exchangeContext);
-<a class="jxr_linenumber" name="1060" href="#1060">1060</a>     }
-<a class="jxr_linenumber" name="1061" href="#1061">1061</a> 
-<a class="jxr_linenumber" name="1062" href="#1062">1062</a>     @Test
-<a class="jxr_linenumber" name="1063" href="#1063">1063</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponsePipelinedEmpty() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1064" href="#1064">1064</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1065" href="#1065">1065</a> 
-<a class="jxr_linenumber" name="1066" href="#1066">1066</a>         state.setRequestState(MessageState.READY);
-<a class="jxr_linenumber" name="1067" href="#1067">1067</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1068" href="#1068">1068</a> 
-<a class="jxr_linenumber" name="1069" href="#1069">1069</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1070" href="#1070">1070</a> 
-<a class="jxr_linenumber" name="1071" href="#1071">1071</a>         Assert.assertEquals(MessageState.READY, state.getRequestState());
-<a class="jxr_linenumber" name="1072" href="#1072">1072</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="1073" href="#1073">1073</a>         Assert.assertNull(state.getOutgoing());
-<a class="jxr_linenumber" name="1074" href="#1074">1074</a> 
-<a class="jxr_linenumber" name="1075" href="#1075">1075</a>         Mockito.verify(conn).suspendOutput();
-<a class="jxr_linenumber" name="1076" href="#1076">1076</a>         Mockito.verifyNoMoreInteractions(requestHandler);
-<a class="jxr_linenumber" name="1077" href="#1077">1077</a>     }
-<a class="jxr_linenumber" name="1078" href="#1078">1078</a> 
-<a class="jxr_linenumber" name="1079" href="#1079">1079</a>     @Test
-<a class="jxr_linenumber" name="1080" href="#1080">1080</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseHandlePipelinedRequest() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1081" href="#1081">1081</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1082" href="#1082">1082</a>         <strong class="jxr_keyword">final</strong> Queue&lt;PipelineEntry&gt; pipeline = state.getPipeline();
-<a class="jxr_linenumber" name="1083" href="#1083">1083</a> 
-<a class="jxr_linenumber" name="1084" href="#1084">1084</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1085" href="#1085">1085</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1086" href="#1086">1086</a>         <strong class="jxr_keyword">final</strong> PipelineEntry entry = <strong class="jxr_keyword">new</strong> PipelineEntry(request, request, <strong class="jxr_keyword">null</strong>, requestHandler, exchangeContext);
-<a class="jxr_linenumber" name="1087" href="#1087">1087</a>         pipeline.add(entry);
-<a class="jxr_linenumber" name="1088" href="#1088">1088</a> 
-<a class="jxr_linenumber" name="1089" href="#1089">1089</a>         state.setRequestState(MessageState.READY);
-<a class="jxr_linenumber" name="1090" href="#1090">1090</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1091" href="#1091">1091</a> 
-<a class="jxr_linenumber" name="1092" href="#1092">1092</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1093" href="#1093">1093</a> 
-<a class="jxr_linenumber" name="1094" href="#1094">1094</a>         Assert.assertEquals(MessageState.READY, state.getRequestState());
-<a class="jxr_linenumber" name="1095" href="#1095">1095</a>         Assert.assertEquals(MessageState.INIT, state.getResponseState());
-<a class="jxr_linenumber" name="1096" href="#1096">1096</a>         Assert.assertNull(state.getOutgoing());
-<a class="jxr_linenumber" name="1097" href="#1097">1097</a> 
-<a class="jxr_linenumber" name="1098" href="#1098">1098</a>         <strong class="jxr_keyword">final</strong> ArgumentCaptor&lt;HttpAsyncExchange&gt; argCaptor = ArgumentCaptor.forClass(HttpAsyncExchange.<strong class="jxr_keyword">class</strong>);
-<a class="jxr_linenumber" name="1099" href="#1099">1099</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.requestHandler).handle(Mockito.same(request),
-<a class="jxr_linenumber" name="1100" href="#1100">1100</a>                 argCaptor.capture(), Mockito.same(exchangeContext));
-<a class="jxr_linenumber" name="1101" href="#1101">1101</a>         <strong class="jxr_keyword">final</strong> HttpAsyncExchange exchange = argCaptor.getValue();
-<a class="jxr_linenumber" name="1102" href="#1102">1102</a> 
-<a class="jxr_linenumber" name="1103" href="#1103">1103</a>         Assert.assertNotNull(exchange);
-<a class="jxr_linenumber" name="1104" href="#1104">1104</a>         Assert.assertSame(request, exchange.getRequest());
-<a class="jxr_linenumber" name="1105" href="#1105">1105</a>         Assert.assertNotNull(exchange.getResponse());
-<a class="jxr_linenumber" name="1106" href="#1106">1106</a>         Assert.assertEquals(200, exchange.getResponse().getStatusLine().getStatusCode());
-<a class="jxr_linenumber" name="1107" href="#1107">1107</a>     }
-<a class="jxr_linenumber" name="1108" href="#1108">1108</a> 
-<a class="jxr_linenumber" name="1109" href="#1109">1109</a>     @Test
-<a class="jxr_linenumber" name="1110" href="#1110">1110</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseHandleFailedPipelinedRequest() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1111" href="#1111">1111</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1112" href="#1112">1112</a>         <strong class="jxr_keyword">final</strong> Queue&lt;PipelineEntry&gt; pipeline = state.getPipeline();
-<a class="jxr_linenumber" name="1113" href="#1113">1113</a> 
-<a class="jxr_linenumber" name="1114" href="#1114">1114</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1115" href="#1115">1115</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1116" href="#1116">1116</a>         <strong class="jxr_keyword">final</strong> Exception ex = <strong class="jxr_keyword">new</strong> Exception(<span class="jxr_string">"Opppsie"</span>);
-<a class="jxr_linenumber" name="1117" href="#1117">1117</a>         <strong class="jxr_keyword">final</strong> PipelineEntry entry = <strong class="jxr_keyword">new</strong> PipelineEntry(request, <strong class="jxr_keyword">null</strong>, ex, requestHandler, exchangeContext);
-<a class="jxr_linenumber" name="1118" href="#1118">1118</a>         pipeline.add(entry);
-<a class="jxr_linenumber" name="1119" href="#1119">1119</a> 
-<a class="jxr_linenumber" name="1120" href="#1120">1120</a>         state.setRequestState(MessageState.READY);
-<a class="jxr_linenumber" name="1121" href="#1121">1121</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1122" href="#1122">1122</a> 
-<a class="jxr_linenumber" name="1123" href="#1123">1123</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1124" href="#1124">1124</a> 
-<a class="jxr_linenumber" name="1125" href="#1125">1125</a>         Assert.assertEquals(MessageState.READY, state.getRequestState());
-<a class="jxr_linenumber" name="1126" href="#1126">1126</a>         Assert.assertEquals(MessageState.BODY_STREAM, state.getResponseState());
-<a class="jxr_linenumber" name="1127" href="#1127">1127</a> 
-<a class="jxr_linenumber" name="1128" href="#1128">1128</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = state.getOutgoing();
-<a class="jxr_linenumber" name="1129" href="#1129">1129</a>         Assert.assertNotNull(outgoing.getProducer());
-<a class="jxr_linenumber" name="1130" href="#1130">1130</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = outgoing.getResponse();
-<a class="jxr_linenumber" name="1131" href="#1131">1131</a>         Assert.assertNotNull(response);
-<a class="jxr_linenumber" name="1132" href="#1132">1132</a>         Assert.assertEquals(500, response.getStatusLine().getStatusCode());
-<a class="jxr_linenumber" name="1133" href="#1133">1133</a> 
-<a class="jxr_linenumber" name="1134" href="#1134">1134</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.requestHandler, Mockito.never()).handle(Mockito.&lt;HttpRequest&gt;any(),
-<a class="jxr_linenumber" name="1135" href="#1135">1135</a>                 Mockito.&lt;HttpAsyncExchange&gt;any(), Mockito.&lt;HttpContext&gt;any());
-<a class="jxr_linenumber" name="1136" href="#1136">1136</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(Mockito.same(response));
-<a class="jxr_linenumber" name="1137" href="#1137">1137</a>     }
-<a class="jxr_linenumber" name="1138" href="#1138">1138</a> 
-<a class="jxr_linenumber" name="1139" href="#1139">1139</a>     @Test(expected=HttpException.<strong class="jxr_keyword">class</strong>)
-<a class="jxr_linenumber" name="1140" href="#1140">1140</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testInvalidResponseStatus() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1141" href="#1141">1141</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1142" href="#1142">1142</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1143" href="#1143">1143</a>         <strong class="jxr_keyword">final</strong> HttpEntityEnclosingRequest request = <strong class="jxr_keyword">new</strong> BasicHttpEntityEnclosingRequest(<span class="jxr_string">"POST"</span>, <span class="jxr_string">"/"</span>,
-<a class="jxr_linenumber" name="1144" href="#1144">1144</a>                 HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1145" href="#1145">1145</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="1146" href="#1146">1146</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="1147" href="#1147">1147</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="1148" href="#1148">1148</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="1149" href="#1149">1149</a>         state.setResponseState(MessageState.INIT);
-<a class="jxr_linenumber" name="1150" href="#1150">1150</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 112, <span class="jxr_string">"Something stupid"</span>);
-<a class="jxr_linenumber" name="1151" href="#1151">1151</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1152" href="#1152">1152</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1153" href="#1153">1153</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1154" href="#1154">1154</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1155" href="#1155">1155</a> 
-<a class="jxr_linenumber" name="1156" href="#1156">1156</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="1157" href="#1157">1157</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.conn.isResponseSubmitted()).thenReturn(Boolean.FALSE);
-<a class="jxr_linenumber" name="1158" href="#1158">1158</a> 
-<a class="jxr_linenumber" name="1159" href="#1159">1159</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1160" href="#1160">1160</a>     }
-<a class="jxr_linenumber" name="1161" href="#1161">1161</a> 
-<a class="jxr_linenumber" name="1162" href="#1162">1162</a>     @Test(expected=HttpException.<strong class="jxr_keyword">class</strong>)
-<a class="jxr_linenumber" name="1163" href="#1163">1163</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testInvalidResponseStatusToExpection() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1164" href="#1164">1164</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1165" href="#1165">1165</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1166" href="#1166">1166</a>         <strong class="jxr_keyword">final</strong> HttpEntityEnclosingRequest request = <strong class="jxr_keyword">new</strong> BasicHttpEntityEnclosingRequest(<span class="jxr_string">"POST"</span>, <span class="jxr_string">"/"</span>,
-<a class="jxr_linenumber" name="1167" href="#1167">1167</a>                 HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1168" href="#1168">1168</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="1169" href="#1169">1169</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="1170" href="#1170">1170</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="1171" href="#1171">1171</a>         state.setRequestState(MessageState.ACK_EXPECTED);
-<a class="jxr_linenumber" name="1172" href="#1172">1172</a>         state.setResponseState(MessageState.READY);
-<a class="jxr_linenumber" name="1173" href="#1173">1173</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="1174" href="#1174">1174</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="1175" href="#1175">1175</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1176" href="#1176">1176</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1177" href="#1177">1177</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1178" href="#1178">1178</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1179" href="#1179">1179</a> 
-<a class="jxr_linenumber" name="1180" href="#1180">1180</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
-<a class="jxr_linenumber" name="1181" href="#1181">1181</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.conn.isResponseSubmitted()).thenReturn(Boolean.FALSE);
-<a class="jxr_linenumber" name="1182" href="#1182">1182</a> 
-<a class="jxr_linenumber" name="1183" href="#1183">1183</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1184" href="#1184">1184</a>     }
-<a class="jxr_linenumber" name="1185" href="#1185">1185</a> 
-<a class="jxr_linenumber" name="1186" href="#1186">1186</a>     @Test
-<a class="jxr_linenumber" name="1187" href="#1187">1187</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseTrigger() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1188" href="#1188">1188</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1189" href="#1189">1189</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="1190" href="#1190">1190</a>         state.setResponseState(MessageState.READY);
-<a class="jxr_linenumber" name="1191" href="#1191">1191</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1192" href="#1192">1192</a> 
-<a class="jxr_linenumber" name="1193" href="#1193">1193</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1194" href="#1194">1194</a>         <strong class="jxr_keyword">final</strong> HttpAsyncExchange httpexchanage = protocolHandler.<strong class="jxr_keyword">new</strong> HttpAsyncExchangeImpl(
-<a class="jxr_linenumber" name="1195" href="#1195">1195</a>                 <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1),
-<a class="jxr_linenumber" name="1196" href="#1196">1196</a>                 <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>),
-<a class="jxr_linenumber" name="1197" href="#1197">1197</a>                 state, <strong class="jxr_keyword">this</strong>.conn, exchangeContext);
-<a class="jxr_linenumber" name="1198" href="#1198">1198</a>         Assert.assertFalse(httpexchanage.isCompleted());
-<a class="jxr_linenumber" name="1199" href="#1199">1199</a>         httpexchanage.submitResponse(<strong class="jxr_keyword">this</strong>.responseProducer);
-<a class="jxr_linenumber" name="1200" href="#1200">1200</a>         Assert.assertTrue(httpexchanage.isCompleted());
-<a class="jxr_linenumber" name="1201" href="#1201">1201</a> 
-<a class="jxr_linenumber" name="1202" href="#1202">1202</a>         Assert.assertEquals(MessageState.COMPLETED, state.getRequestState());
-<a class="jxr_linenumber" name="1203" href="#1203">1203</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="1204" href="#1204">1204</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = state.getOutgoing();
-<a class="jxr_linenumber" name="1205" href="#1205">1205</a>         Assert.assertNotNull(outgoing);
-<a class="jxr_linenumber" name="1206" href="#1206">1206</a>         Assert.assertSame(<strong class="jxr_keyword">this</strong>.responseProducer, outgoing.getProducer());
-<a class="jxr_linenumber" name="1207" href="#1207">1207</a> 
-<a class="jxr_linenumber" name="1208" href="#1208">1208</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).requestOutput();
-<a class="jxr_linenumber" name="1209" href="#1209">1209</a> 
-<a class="jxr_linenumber" name="1210" href="#1210">1210</a>         <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="1211" href="#1211">1211</a>             httpexchanage.submitResponse(Mockito.mock(HttpAsyncResponseProducer.<strong class="jxr_keyword">class</strong>));
-<a class="jxr_linenumber" name="1212" href="#1212">1212</a>             Assert.fail(<span class="jxr_string">"IllegalStateException expected"</span>);
-<a class="jxr_linenumber" name="1213" href="#1213">1213</a>         } <strong class="jxr_keyword">catch</strong> (<strong class="jxr_keyword">final</strong> IllegalStateException ex) {
-<a class="jxr_linenumber" name="1214" href="#1214">1214</a>         }
-<a class="jxr_linenumber" name="1215" href="#1215">1215</a>     }
-<a class="jxr_linenumber" name="1216" href="#1216">1216</a> 
-<a class="jxr_linenumber" name="1217" href="#1217">1217</a>     @Test(expected=IllegalArgumentException.<strong class="jxr_keyword">class</strong>)
-<a class="jxr_linenumber" name="1218" href="#1218">1218</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseTriggerInvalidResponseProducer() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1219" href="#1219">1219</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1220" href="#1220">1220</a>         state.setRequestState(MessageState.ACK_EXPECTED);
-<a class="jxr_linenumber" name="1221" href="#1221">1221</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1222" href="#1222">1222</a> 
-<a class="jxr_linenumber" name="1223" href="#1223">1223</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1224" href="#1224">1224</a>         <strong class="jxr_keyword">final</strong> HttpAsyncExchange httpexchanage = protocolHandler.<strong class="jxr_keyword">new</strong> HttpAsyncExchangeImpl(
-<a class="jxr_linenumber" name="1225" href="#1225">1225</a>                 <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1),
-<a class="jxr_linenumber" name="1226" href="#1226">1226</a>                 <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>),
-<a class="jxr_linenumber" name="1227" href="#1227">1227</a>                 state, <strong class="jxr_keyword">this</strong>.conn, exchangeContext);
-<a class="jxr_linenumber" name="1228" href="#1228">1228</a>         httpexchanage.submitResponse(<strong class="jxr_keyword">null</strong>);
-<a class="jxr_linenumber" name="1229" href="#1229">1229</a>     }
-<a class="jxr_linenumber" name="1230" href="#1230">1230</a> 
-<a class="jxr_linenumber" name="1231" href="#1231">1231</a>     @Test
-<a class="jxr_linenumber" name="1232" href="#1232">1232</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseContent() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1233" href="#1233">1233</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1234" href="#1234">1234</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="1235" href="#1235">1235</a>         state.setResponseState(MessageState.BODY_STREAM);
-<a class="jxr_linenumber" name="1236" href="#1236">1236</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1237" href="#1237">1237</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1238" href="#1238">1238</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="1239" href="#1239">1239</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="1240" href="#1240">1240</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1241" href="#1241">1241</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1242" href="#1242">1242</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1243" href="#1243">1243</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1244" href="#1244">1244</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.encoder.isCompleted()).thenReturn(Boolean.FALSE);
-<a class="jxr_linenumber" name="1245" href="#1245">1245</a> 
-<a class="jxr_linenumber" name="1246" href="#1246">1246</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.outputReady(conn, <strong class="jxr_keyword">this</strong>.encoder);
-<a class="jxr_linenumber" name="1247" href="#1247">1247</a> 
-<a class="jxr_linenumber" name="1248" href="#1248">1248</a>         Assert.assertEquals(MessageState.COMPLETED, state.getRequestState());
-<a class="jxr_linenumber" name="1249" href="#1249">1249</a>         Assert.assertEquals(MessageState.BODY_STREAM, state.getResponseState());
-<a class="jxr_linenumber" name="1250" href="#1250">1250</a> 
-<a class="jxr_linenumber" name="1251" href="#1251">1251</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).produceContent(<strong class="jxr_keyword">this</strong>.encoder, <strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1252" href="#1252">1252</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).requestInput();
-<a class="jxr_linenumber" name="1253" href="#1253">1253</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
-<a class="jxr_linenumber" name="1254" href="#1254">1254</a>     }
-<a class="jxr_linenumber" name="1255" href="#1255">1255</a> 
-<a class="jxr_linenumber" name="1256" href="#1256">1256</a>     @Test
-<a class="jxr_linenumber" name="1257" href="#1257">1257</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseContentCompleted() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1258" href="#1258">1258</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1259" href="#1259">1259</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="1260" href="#1260">1260</a>         state.setResponseState(MessageState.BODY_STREAM);
-<a class="jxr_linenumber" name="1261" href="#1261">1261</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1262" href="#1262">1262</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1263" href="#1263">1263</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="1264" href="#1264">1264</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="1265" href="#1265">1265</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1266" href="#1266">1266</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1267" href="#1267">1267</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1268" href="#1268">1268</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1269" href="#1269">1269</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.encoder.isCompleted()).thenReturn(<strong class="jxr_keyword">true</strong>);
-<a class="jxr_linenumber" name="1270" href="#1270">1270</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.TRUE);
-<a class="jxr_linenumber" name="1271" href="#1271">1271</a> 
-<a class="jxr_linenumber" name="1272" href="#1272">1272</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.outputReady(conn, <strong class="jxr_keyword">this</strong>.encoder);
-<a class="jxr_linenumber" name="1273" href="#1273">1273</a> 
-<a class="jxr_linenumber" name="1274" href="#1274">1274</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="1275" href="#1275">1275</a> 
-<a class="jxr_linenumber" name="1276" href="#1276">1276</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).produceContent(<strong class="jxr_keyword">this</strong>.encoder, <strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1277" href="#1277">1277</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).responseCompleted(exchangeContext);
-<a class="jxr_linenumber" name="1278" href="#1278">1278</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).requestInput();
-<a class="jxr_linenumber" name="1279" href="#1279">1279</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
-<a class="jxr_linenumber" name="1280" href="#1280">1280</a>     }
-<a class="jxr_linenumber" name="1281" href="#1281">1281</a> 
-<a class="jxr_linenumber" name="1282" href="#1282">1282</a>     @Test
-<a class="jxr_linenumber" name="1283" href="#1283">1283</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testResponseContentCompletedNoKeepAlive() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1284" href="#1284">1284</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1285" href="#1285">1285</a>         state.setRequestState(MessageState.COMPLETED);
-<a class="jxr_linenumber" name="1286" href="#1286">1286</a>         state.setResponseState(MessageState.BODY_STREAM);
-<a class="jxr_linenumber" name="1287" href="#1287">1287</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1288" href="#1288">1288</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1289" href="#1289">1289</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="1290" href="#1290">1290</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
-<a class="jxr_linenumber" name="1291" href="#1291">1291</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1292" href="#1292">1292</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1293" href="#1293">1293</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1294" href="#1294">1294</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1295" href="#1295">1295</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.encoder.isCompleted()).thenReturn(<strong class="jxr_keyword">true</strong>);
-<a class="jxr_linenumber" name="1296" href="#1296">1296</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.FALSE);
-<a class="jxr_linenumber" name="1297" href="#1297">1297</a> 
-<a class="jxr_linenumber" name="1298" href="#1298">1298</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.outputReady(conn, <strong class="jxr_keyword">this</strong>.encoder);
-<a class="jxr_linenumber" name="1299" href="#1299">1299</a> 
-<a class="jxr_linenumber" name="1300" href="#1300">1300</a>         Assert.assertEquals(MessageState.READY, state.getResponseState());
-<a class="jxr_linenumber" name="1301" href="#1301">1301</a> 
-<a class="jxr_linenumber" name="1302" href="#1302">1302</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).produceContent(<strong class="jxr_keyword">this</strong>.encoder, <strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1303" href="#1303">1303</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).responseCompleted(exchangeContext);
-<a class="jxr_linenumber" name="1304" href="#1304">1304</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).requestInput();
-<a class="jxr_linenumber" name="1305" href="#1305">1305</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).close();
-<a class="jxr_linenumber" name="1306" href="#1306">1306</a>     }
-<a class="jxr_linenumber" name="1307" href="#1307">1307</a> 
-<a class="jxr_linenumber" name="1308" href="#1308">1308</a>     @Test
-<a class="jxr_linenumber" name="1309" href="#1309">1309</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testEndOfInput() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1310" href="#1310">1310</a> 
-<a class="jxr_linenumber" name="1311" href="#1311">1311</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.conn.getSocketTimeout()).thenReturn(1000);
-<a class="jxr_linenumber" name="1312" href="#1312">1312</a> 
-<a class="jxr_linenumber" name="1313" href="#1313">1313</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.endOfInput(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1314" href="#1314">1314</a> 
-<a class="jxr_linenumber" name="1315" href="#1315">1315</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).setSocketTimeout(Mockito.anyInt());
-<a class="jxr_linenumber" name="1316" href="#1316">1316</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).close();
-<a class="jxr_linenumber" name="1317" href="#1317">1317</a>     }
-<a class="jxr_linenumber" name="1318" href="#1318">1318</a> 
-<a class="jxr_linenumber" name="1319" href="#1319">1319</a>     @Test
-<a class="jxr_linenumber" name="1320" href="#1320">1320</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testEndOfInputNoTimeout() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1321" href="#1321">1321</a> 
-<a class="jxr_linenumber" name="1322" href="#1322">1322</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.conn.getSocketTimeout()).thenReturn(0);
-<a class="jxr_linenumber" name="1323" href="#1323">1323</a> 
-<a class="jxr_linenumber" name="1324" href="#1324">1324</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.endOfInput(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1325" href="#1325">1325</a> 
-<a class="jxr_linenumber" name="1326" href="#1326">1326</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).setSocketTimeout(1000);
-<a class="jxr_linenumber" name="1327" href="#1327">1327</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).close();
-<a class="jxr_linenumber" name="1328" href="#1328">1328</a>     }
-<a class="jxr_linenumber" name="1329" href="#1329">1329</a> 
-<a class="jxr_linenumber" name="1330" href="#1330">1330</a>     @Test
-<a class="jxr_linenumber" name="1331" href="#1331">1331</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testTimeoutActiveConnection() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1332" href="#1332">1332</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1333" href="#1333">1333</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1334" href="#1334">1334</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.conn.getStatus()).thenReturn(NHttpClientConnection.ACTIVE, NHttpClientConnection.CLOSED);
-<a class="jxr_linenumber" name="1335" href="#1335">1335</a> 
-<a class="jxr_linenumber" name="1336" href="#1336">1336</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.timeout(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1337" href="#1337">1337</a> 
-<a class="jxr_linenumber" name="1338" href="#1338">1338</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).close();
-<a class="jxr_linenumber" name="1339" href="#1339">1339</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).setSocketTimeout(Mockito.anyInt());
-<a class="jxr_linenumber" name="1340" href="#1340">1340</a>     }
-<a class="jxr_linenumber" name="1341" href="#1341">1341</a> 
-<a class="jxr_linenumber" name="1342" href="#1342">1342</a>     @Test
-<a class="jxr_linenumber" name="1343" href="#1343">1343</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testTimeoutActiveConnectionBufferedData() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1344" href="#1344">1344</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1345" href="#1345">1345</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1346" href="#1346">1346</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.conn.getStatus()).thenReturn(NHttpClientConnection.ACTIVE, NHttpClientConnection.CLOSING);
-<a class="jxr_linenumber" name="1347" href="#1347">1347</a> 
-<a class="jxr_linenumber" name="1348" href="#1348">1348</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.timeout(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1349" href="#1349">1349</a> 
-<a class="jxr_linenumber" name="1350" href="#1350">1350</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).close();
-<a class="jxr_linenumber" name="1351" href="#1351">1351</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).setSocketTimeout(250);
-<a class="jxr_linenumber" name="1352" href="#1352">1352</a>     }
-<a class="jxr_linenumber" name="1353" href="#1353">1353</a> 
-<a class="jxr_linenumber" name="1354" href="#1354">1354</a>     @Test
-<a class="jxr_linenumber" name="1355" href="#1355">1355</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testTimeoutClosingConnection() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="1356" href="#1356">1356</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
-<a class="jxr_linenumber" name="1357" href="#1357">1357</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
-<a class="jxr_linenumber" name="1358" href="#1358">1358</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
-<a class="jxr_linenumber" name="1359" href="#1359">1359</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
-<a class="jxr_linenumber" name="1360" href="#1360">1360</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
-<a class="jxr_linenumber" name="1361" href="#1361">1361</a>         state.setIncoming(incoming);
-<a class="jxr_linenumber" name="1362" href="#1362">1362</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
-<a class="jxr_linenumber" name="1363" href="#1363">1363</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
-<a class="jxr_linenumber" name="1364" href="#1364">1364</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
-<a class="jxr_linenumber" name="1365" href="#1365">1365</a>         state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1366" href="#1366">1366</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
-<a class="jxr_linenumber" name="1367" href="#1367">1367</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.conn.getStatus()).thenReturn(NHttpClientConnection.CLOSING);
-<a class="jxr_linenumber" name="1368" href="#1368">1368</a> 
-<a class="jxr_linenumber" name="1369" href="#1369">1369</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.timeout(<strong class="jxr_keyword">this</strong>.conn);
-<a class="jxr_linenumber" name="1370" href="#1370">1370</a> 
-<a class="jxr_linenumber" name="1371" href="#1371">1371</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).shutdown();
-<a class="jxr_linenumber" name="1372" href="#1372">1372</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.requestConsumer).failed(Mockito.any(SocketTimeoutException.<strong class="jxr_keyword">class</strong>));
-<a class="jxr_linenumber" name="1373" href="#1373">1373</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.requestConsumer).close();
-<a class="jxr_linenumber" name="1374" href="#1374">1374</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).failed(Mockito.any(SocketTimeoutException.<strong class="jxr_keyword">class</strong>));
-<a class="jxr_linenumber" name="1375" href="#1375">1375</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.responseProducer).close();
-<a class="jxr_linenumber" name="1376" href="#1376">1376</a>     }
-<a class="jxr_linenumber" name="1377" href="#1377">1377</a> 
-<a class="jxr_linenumber" name="1378" href="#1378">1378</a> }
+<a class="jxr_linenumber" name="830" href="#830">830</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
+<a class="jxr_linenumber" name="831" href="#831">831</a>     }
+<a class="jxr_linenumber" name="832" href="#832">832</a> 
+<a class="jxr_linenumber" name="833" href="#833">833</a>     @Test
+<a class="jxr_linenumber" name="834" href="#834">834</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testBasicResponseWithPipelining() <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="835" href="#835">835</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
+<a class="jxr_linenumber" name="836" href="#836">836</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
+<a class="jxr_linenumber" name="837" href="#837">837</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
+<a class="jxr_linenumber" name="838" href="#838">838</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
+<a class="jxr_linenumber" name="839" href="#839">839</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
+<a class="jxr_linenumber" name="840" href="#840">840</a>         state.setIncoming(incoming);
+<a class="jxr_linenumber" name="841" href="#841">841</a>         state.setRequestState(MessageState.COMPLETED);
+<a class="jxr_linenumber" name="842" href="#842">842</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
+<a class="jxr_linenumber" name="843" href="#843">843</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
+<a class="jxr_linenumber" name="844" href="#844">844</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
+<a class="jxr_linenumber" name="845" href="#845">845</a>         response.setEntity(<strong class="jxr_keyword">new</strong> NStringEntity(<span class="jxr_string">"stuff"</span>));
+<a class="jxr_linenumber" name="846" href="#846">846</a>         state.setOutgoing(outgoing);
+<a class="jxr_linenumber" name="847" href="#847">847</a> 
+<a class="jxr_linenumber" name="848" href="#848">848</a>         <strong class="jxr_keyword">final</strong> Queue&lt;PipelineEntry&gt; pipeline = state.getPipeline();
+<a class="jxr_linenumber" name="849" href="#849">849</a> 
+<a class="jxr_linenumber" name="850" href="#850">850</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext2 = <strong class="jxr_keyword">new</strong> BasicHttpContext();
+<a class="jxr_linenumber" name="851" href="#851">851</a>         <strong class="jxr_keyword">final</strong> HttpRequest pipelinedRequest = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
+<a class="jxr_linenumber" name="852" href="#852">852</a>         <strong class="jxr_keyword">final</strong> PipelineEntry entry = <strong class="jxr_keyword">new</strong> PipelineEntry(pipelinedRequest, pipelinedRequest,
+<a class="jxr_linenumber" name="853" href="#853">853</a>                 <strong class="jxr_keyword">null</strong>, requestHandler, exchangeContext2);
+<a class="jxr_linenumber" name="854" href="#854">854</a>         pipeline.add(entry);
+<a class="jxr_linenumber" name="855" href="#855">855</a> 
+<a class="jxr_linenumber" name="856" href="#856">856</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
+<a class="jxr_linenumber" name="857" href="#857">857</a> 
+<a class="jxr_linenumber" name="858" href="#858">858</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
+<a class="jxr_linenumber" name="859" href="#859">859</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.TRUE);
+<a class="jxr_linenumber" name="860" href="#860">860</a> 
+<a class="jxr_linenumber" name="861" href="#861">861</a>         <strong class="jxr_keyword">this</strong>.protocolHandler.responseReady(<strong class="jxr_keyword">this</strong>.conn);
+<a class="jxr_linenumber" name="862" href="#862">862</a> 
+<a class="jxr_linenumber" name="863" href="#863">863</a>         Assert.assertEquals(MessageState.BODY_STREAM, state.getResponseState());
+<a class="jxr_linenumber" name="864" href="#864">864</a> 
+<a class="jxr_linenumber" name="865" href="#865">865</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.httpProcessor).process(response, exchangeContext);
+<a class="jxr_linenumber" name="866" href="#866">866</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).suspendOutput();
+<a class="jxr_linenumber" name="867" href="#867">867</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn).submitResponse(response);
+<a class="jxr_linenumber" name="868" href="#868">868</a>         Mockito.verify(<strong class="jxr_keyword">this</strong>.conn, Mockito.never()).close();
+<a class="jxr_linenumber" name="869" href="#869">869</a>     }
+<a class="jxr_linenumber" name="870" href="#870">870</a> 
+<a class="jxr_linenumber" name="871" href="#871">871</a>     @Test
+<a class="jxr_linenumber" name="872" href="#872">872</a>     <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testBasicResponseNoKeepAlive() <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="873" href="#873">873</a>         <strong class="jxr_keyword">final</strong> State state = <strong class="jxr_keyword">new</strong> State();
+<a class="jxr_linenumber" name="874" href="#874">874</a>         <strong class="jxr_keyword">final</strong> HttpContext exchangeContext = <strong class="jxr_keyword">new</strong> BasicHttpContext();
+<a class="jxr_linenumber" name="875" href="#875">875</a>         <strong class="jxr_keyword">final</strong> HttpRequest request = <strong class="jxr_keyword">new</strong> BasicHttpRequest(<span class="jxr_string">"GET"</span>, <span class="jxr_string">"/"</span>, HttpVersion.HTTP_1_1);
+<a class="jxr_linenumber" name="876" href="#876">876</a>         <strong class="jxr_keyword">final</strong> Incoming incoming = <strong class="jxr_keyword">new</strong> Incoming(
+<a class="jxr_linenumber" name="877" href="#877">877</a>                 request, <strong class="jxr_keyword">this</strong>.requestHandler, <strong class="jxr_keyword">this</strong>.requestConsumer, exchangeContext);
+<a class="jxr_linenumber" name="878" href="#878">878</a>         state.setIncoming(incoming);
+<a class="jxr_linenumber" name="879" href="#879">879</a>         state.setRequestState(MessageState.COMPLETED);
+<a class="jxr_linenumber" name="880" href="#880">880</a>         <strong class="jxr_keyword">final</strong> HttpResponse response = <strong class="jxr_keyword">new</strong> BasicHttpResponse(HttpVersion.HTTP_1_1, 200, <span class="jxr_string">"OK"</span>);
+<a class="jxr_linenumber" name="881" href="#881">881</a>         <strong class="jxr_keyword">final</strong> Outgoing outgoing = <strong class="jxr_keyword">new</strong> Outgoing(
+<a class="jxr_linenumber" name="882" href="#882">882</a>                 request, response, <strong class="jxr_keyword">this</strong>.responseProducer, exchangeContext);
+<a class="jxr_linenumber" name="883" href="#883">883</a>         state.setOutgoing(outgoing);
+<a class="jxr_linenumber" name="884" href="#884">884</a>         state.setResponseState(MessageState.INIT);
+<a class="jxr_linenumber" name="885" href="#885">885</a>         <strong class="jxr_keyword">this</strong>.connContext.setAttribute(HttpAsyncService.HTTP_EXCHANGE_STATE, state);
+<a class="jxr_linenumber" name="886" href="#886">886</a> 
+<a class="jxr_linenumber" name="887" href="#887">887</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.responseProducer.generateResponse()).thenReturn(response);
+<a class="jxr_linenumber" name="888" href="#888">888</a>         Mockito.when(<strong class="jxr_keyword">this</strong>.reuseStrategy.keepAlive(response, exchangeContext)).thenReturn(Boolean.FALSE);
+<a class="jxr_linenumber" name="889" href="#889">889</a> 

[... 492 lines stripped ...]



Mime
View raw message