<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html>
<head>
<!-- Generated by HsColour, http://www.cs.york.ac.uk/fp/darcs/hscolour/ -->
<title>Network/HTTP/HandleStream.hs</title>
<link type='text/css' rel='stylesheet' href='hscolour.css' />
</head>
<body>
<pre><a name="line-1"></a><span class='hs-comment'>-----------------------------------------------------------------------------</span>
<a name="line-2"></a><span class='hs-comment'>-- |</span>
<a name="line-3"></a><span class='hs-comment'>-- Module : Network.HTTP.HandleStream</span>
<a name="line-4"></a><span class='hs-comment'>-- Copyright : (c) 2008- Sigbjorn Finne</span>
<a name="line-5"></a><span class='hs-comment'>-- License : BSD</span>
<a name="line-6"></a><span class='hs-comment'>-- </span>
<a name="line-7"></a><span class='hs-comment'>-- Maintainer : Sigbjorn Finne <sigbjorn.finne@gmail.com></span>
<a name="line-8"></a><span class='hs-comment'>-- Stability : experimental</span>
<a name="line-9"></a><span class='hs-comment'>-- Portability : non-portable (not tested)</span>
<a name="line-10"></a><span class='hs-comment'>--</span>
<a name="line-11"></a><span class='hs-comment'>-- A 'HandleStream'-based version of "Network.HTTP" interface.</span>
<a name="line-12"></a><span class='hs-comment'>--</span>
<a name="line-13"></a><span class='hs-comment'>-- For more detailed information about what the individual exports do, please consult</span>
<a name="line-14"></a><span class='hs-comment'>-- the documentation for "Network.HTTP". /Notice/ however that the functions here do</span>
<a name="line-15"></a><span class='hs-comment'>-- not perform any kind of normalization prior to transmission (or receipt); you are</span>
<a name="line-16"></a><span class='hs-comment'>-- responsible for doing any such yourself, or, if you prefer, just switch to using</span>
<a name="line-17"></a><span class='hs-comment'>-- "Network.HTTP" function instead.</span>
<a name="line-18"></a><span class='hs-comment'>-- </span>
<a name="line-19"></a><span class='hs-comment'>-----------------------------------------------------------------------------</span>
<a name="line-20"></a><span class='hs-keyword'>module</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>HTTP</span><span class='hs-varop'>.</span><span class='hs-conid'>HandleStream</span>
<a name="line-21"></a> <span class='hs-layout'>(</span> <span class='hs-varid'>simpleHTTP</span> <span class='hs-comment'>-- :: Request ty -> IO (Result (Response ty))</span>
<a name="line-22"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>simpleHTTP_</span> <span class='hs-comment'>-- :: HStream ty => HandleStream ty -> Request ty -> IO (Result (Response ty))</span>
<a name="line-23"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendHTTP</span> <span class='hs-comment'>-- :: HStream ty => HandleStream ty -> Request ty -> IO (Result (Response ty))</span>
<a name="line-24"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendHTTP_notify</span> <span class='hs-comment'>-- :: HStream ty => HandleStream ty -> Request ty -> IO () -> IO (Result (Response ty))</span>
<a name="line-25"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>receiveHTTP</span> <span class='hs-comment'>-- :: HStream ty => HandleStream ty -> IO (Result (Request ty))</span>
<a name="line-26"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>respondHTTP</span> <span class='hs-comment'>-- :: HStream ty => HandleStream ty -> Response ty -> IO ()</span>
<a name="line-27"></a>
<a name="line-28"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>simpleHTTP_debug</span> <span class='hs-comment'>-- :: FilePath -> Request DebugString -> IO (Response DebugString)</span>
<a name="line-29"></a> <span class='hs-layout'>)</span> <span class='hs-keyword'>where</span>
<a name="line-30"></a>
<a name="line-31"></a><span class='hs-comment'>-----------------------------------------------------------------</span>
<a name="line-32"></a><span class='hs-comment'>------------------ Imports --------------------------------------</span>
<a name="line-33"></a><span class='hs-comment'>-----------------------------------------------------------------</span>
<a name="line-34"></a>
<a name="line-35"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>BufferType</span>
<a name="line-36"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Stream</span> <span class='hs-layout'>(</span> <span class='hs-varid'>fmapE</span><span class='hs-layout'>,</span> <span class='hs-conid'>Result</span> <span class='hs-layout'>)</span>
<a name="line-37"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>StreamDebugger</span> <span class='hs-layout'>(</span> <span class='hs-varid'>debugByteStream</span> <span class='hs-layout'>)</span>
<a name="line-38"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>TCP</span> <span class='hs-layout'>(</span><span class='hs-conid'>HStream</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>,</span> <span class='hs-conid'>HandleStream</span> <span class='hs-layout'>)</span>
<a name="line-39"></a>
<a name="line-40"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>HTTP</span><span class='hs-varop'>.</span><span class='hs-conid'>Base</span>
<a name="line-41"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>HTTP</span><span class='hs-varop'>.</span><span class='hs-conid'>Headers</span>
<a name="line-42"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>HTTP</span><span class='hs-varop'>.</span><span class='hs-conid'>Utils</span> <span class='hs-layout'>(</span> <span class='hs-varid'>trim</span><span class='hs-layout'>,</span> <span class='hs-varid'>readsOne</span> <span class='hs-layout'>)</span>
<a name="line-43"></a>
<a name="line-44"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Char</span> <span class='hs-layout'>(</span><span class='hs-varid'>toLower</span><span class='hs-layout'>)</span>
<a name="line-45"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Maybe</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromMaybe</span><span class='hs-layout'>)</span>
<a name="line-46"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Monad</span> <span class='hs-layout'>(</span><span class='hs-varid'>when</span><span class='hs-layout'>)</span>
<a name="line-47"></a>
<a name="line-48"></a><span class='hs-comment'>-----------------------------------------------------------------</span>
<a name="line-49"></a><span class='hs-comment'>------------------ Misc -----------------------------------------</span>
<a name="line-50"></a><span class='hs-comment'>-----------------------------------------------------------------</span>
<a name="line-51"></a>
<a name="line-52"></a><a name="simpleHTTP"></a><span class='hs-comment'>-- | @simpleHTTP@ transmits a resource across a non-persistent connection.</span>
<a name="line-53"></a><span class='hs-definition'>simpleHTTP</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Request</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-54"></a><span class='hs-definition'>simpleHTTP</span> <span class='hs-varid'>r</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-55"></a> <span class='hs-varid'>auth</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getAuth</span> <span class='hs-varid'>r</span>
<a name="line-56"></a> <span class='hs-varid'>c</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>openStream</span> <span class='hs-layout'>(</span><span class='hs-varid'>host</span> <span class='hs-varid'>auth</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromMaybe</span> <span class='hs-num'>80</span> <span class='hs-layout'>(</span><span class='hs-varid'>port</span> <span class='hs-varid'>auth</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-57"></a> <span class='hs-varid'>simpleHTTP_</span> <span class='hs-varid'>c</span> <span class='hs-varid'>r</span>
<a name="line-58"></a>
<a name="line-59"></a><a name="simpleHTTP_debug"></a><span class='hs-comment'>-- | @simpleHTTP_debug debugFile req@ behaves like 'simpleHTTP', but logs</span>
<a name="line-60"></a><span class='hs-comment'>-- the HTTP operation via the debug file @debugFile@.</span>
<a name="line-61"></a><span class='hs-definition'>simpleHTTP_debug</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>FilePath</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-62"></a><span class='hs-definition'>simpleHTTP_debug</span> <span class='hs-varid'>httpLogFile</span> <span class='hs-varid'>r</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-63"></a> <span class='hs-varid'>auth</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getAuth</span> <span class='hs-varid'>r</span>
<a name="line-64"></a> <span class='hs-varid'>c0</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>openStream</span> <span class='hs-layout'>(</span><span class='hs-varid'>host</span> <span class='hs-varid'>auth</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromMaybe</span> <span class='hs-num'>80</span> <span class='hs-layout'>(</span><span class='hs-varid'>port</span> <span class='hs-varid'>auth</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-65"></a> <span class='hs-varid'>c</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>debugByteStream</span> <span class='hs-varid'>httpLogFile</span> <span class='hs-varid'>c0</span>
<a name="line-66"></a> <span class='hs-varid'>simpleHTTP_</span> <span class='hs-varid'>c</span> <span class='hs-varid'>r</span>
<a name="line-67"></a>
<a name="line-68"></a><a name="simpleHTTP_"></a><span class='hs-comment'>-- | Like 'simpleHTTP', but acting on an already opened stream.</span>
<a name="line-69"></a><span class='hs-definition'>simpleHTTP_</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-70"></a><span class='hs-definition'>simpleHTTP_</span> <span class='hs-varid'>s</span> <span class='hs-varid'>r</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sendHTTP</span> <span class='hs-varid'>s</span> <span class='hs-varid'>r</span>
<a name="line-71"></a>
<a name="line-72"></a><a name="sendHTTP"></a><span class='hs-comment'>-- | @sendHTTP hStream httpRequest@ transmits @httpRequest@ over</span>
<a name="line-73"></a><span class='hs-comment'>-- @hStream@, but does not alter the status of the connection, nor request it to be</span>
<a name="line-74"></a><span class='hs-comment'>-- closed upon receiving the response.</span>
<a name="line-75"></a><span class='hs-definition'>sendHTTP</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-76"></a><span class='hs-definition'>sendHTTP</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>rq</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sendHTTP_notify</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>rq</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-77"></a>
<a name="line-78"></a><a name="sendHTTP_notify"></a><span class='hs-comment'>-- | @sendHTTP_notify hStream httpRequest action@ behaves like 'sendHTTP', but</span>
<a name="line-79"></a><span class='hs-comment'>-- lets you supply an IO @action@ to execute once the request has been successfully</span>
<a name="line-80"></a><span class='hs-comment'>-- transmitted over the connection. Useful when you want to set up tracing of</span>
<a name="line-81"></a><span class='hs-comment'>-- request transmission and its performance.</span>
<a name="line-82"></a><span class='hs-definition'>sendHTTP_notify</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span>
<a name="line-83"></a> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span>
<a name="line-84"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-varid'>ty</span>
<a name="line-85"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-86"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-87"></a><span class='hs-definition'>sendHTTP_notify</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>rq</span> <span class='hs-varid'>onSendComplete</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-88"></a> <span class='hs-varid'>when</span> <span class='hs-varid'>providedClose</span> <span class='hs-varop'>$</span> <span class='hs-layout'>(</span><span class='hs-varid'>closeOnEnd</span> <span class='hs-varid'>conn</span> <span class='hs-conid'>True</span><span class='hs-layout'>)</span>
<a name="line-89"></a> <span class='hs-varid'>catchIO</span> <span class='hs-layout'>(</span><span class='hs-varid'>sendMain</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>rq</span> <span class='hs-varid'>onSendComplete</span><span class='hs-layout'>)</span>
<a name="line-90"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>e</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span> <span class='hs-layout'>{</span> <span class='hs-varid'>close</span> <span class='hs-varid'>conn</span><span class='hs-layout'>;</span> <span class='hs-varid'>ioError</span> <span class='hs-varid'>e</span> <span class='hs-layout'>}</span><span class='hs-layout'>)</span>
<a name="line-91"></a> <span class='hs-keyword'>where</span>
<a name="line-92"></a> <span class='hs-varid'>providedClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>findConnClose</span> <span class='hs-layout'>(</span><span class='hs-varid'>rqHeaders</span> <span class='hs-varid'>rq</span><span class='hs-layout'>)</span>
<a name="line-93"></a>
<a name="line-94"></a><a name="sendMain"></a><span class='hs-comment'>-- From RFC 2616, section 8.2.3:</span>
<a name="line-95"></a><span class='hs-comment'>-- 'Because of the presence of older implementations, the protocol allows</span>
<a name="line-96"></a><span class='hs-comment'>-- ambiguous situations in which a client may send "Expect: 100-</span>
<a name="line-97"></a><span class='hs-comment'>-- continue" without receiving either a 417 (Expectation Failed) status</span>
<a name="line-98"></a><span class='hs-comment'>-- or a 100 (Continue) status. Therefore, when a client sends this</span>
<a name="line-99"></a><span class='hs-comment'>-- header field to an origin server (possibly via a proxy) from which it</span>
<a name="line-100"></a><span class='hs-comment'>-- has never seen a 100 (Continue) status, the client SHOULD NOT wait</span>
<a name="line-101"></a><span class='hs-comment'>-- for an indefinite period before sending the request body.'</span>
<a name="line-102"></a><span class='hs-comment'>--</span>
<a name="line-103"></a><span class='hs-comment'>-- Since we would wait forever, I have disabled use of 100-continue for now.</span>
<a name="line-104"></a><span class='hs-definition'>sendMain</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span>
<a name="line-105"></a> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span>
<a name="line-106"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-varid'>ty</span>
<a name="line-107"></a> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-conid'>IO</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-108"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-109"></a><span class='hs-definition'>sendMain</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>rqst</span> <span class='hs-varid'>onSendComplete</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-110"></a> <span class='hs-comment'>--let str = if null (rqBody rqst)</span>
<a name="line-111"></a> <span class='hs-comment'>-- then show rqst</span>
<a name="line-112"></a> <span class='hs-comment'>-- else show (insertHeader HdrExpect "100-continue" rqst)</span>
<a name="line-113"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>conn</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_fromStr</span> <span class='hs-varid'>bufferOps</span> <span class='hs-varop'>$</span> <span class='hs-varid'>show</span> <span class='hs-varid'>rqst</span><span class='hs-layout'>)</span>
<a name="line-114"></a> <span class='hs-comment'>-- write body immediately, don't wait for 100 CONTINUE</span>
<a name="line-115"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>conn</span> <span class='hs-layout'>(</span><span class='hs-varid'>rqBody</span> <span class='hs-varid'>rqst</span><span class='hs-layout'>)</span>
<a name="line-116"></a> <span class='hs-varid'>onSendComplete</span>
<a name="line-117"></a> <span class='hs-varid'>rsp</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getResponseHead</span> <span class='hs-varid'>conn</span>
<a name="line-118"></a> <span class='hs-varid'>switchResponse</span> <span class='hs-varid'>conn</span> <span class='hs-conid'>True</span> <span class='hs-conid'>False</span> <span class='hs-varid'>rsp</span> <span class='hs-varid'>rqst</span>
<a name="line-119"></a>
<a name="line-120"></a> <span class='hs-comment'>-- Hmmm, this could go bad if we keep getting "100 Continue"</span>
<a name="line-121"></a> <span class='hs-comment'>-- responses... Except this should never happen according</span>
<a name="line-122"></a> <span class='hs-comment'>-- to the RFC.</span>
<a name="line-123"></a>
<a name="line-124"></a><a name="switchResponse"></a><span class='hs-definition'>switchResponse</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span>
<a name="line-125"></a> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span>
<a name="line-126"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span> <span class='hs-comment'>{- allow retry? -}</span>
<a name="line-127"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span> <span class='hs-comment'>{- is body sent? -}</span>
<a name="line-128"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Result</span> <span class='hs-conid'>ResponseData</span>
<a name="line-129"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-varid'>ty</span>
<a name="line-130"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-131"></a><span class='hs-definition'>switchResponse</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-layout'>(</span><span class='hs-conid'>Left</span> <span class='hs-varid'>e</span><span class='hs-layout'>)</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-conid'>Left</span> <span class='hs-varid'>e</span><span class='hs-layout'>)</span>
<a name="line-132"></a> <span class='hs-comment'>-- retry on connreset?</span>
<a name="line-133"></a> <span class='hs-comment'>-- if we attempt to use the same socket then there is an excellent</span>
<a name="line-134"></a> <span class='hs-comment'>-- chance that the socket is not in a completely closed state.</span>
<a name="line-135"></a>
<a name="line-136"></a><span class='hs-definition'>switchResponse</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>allow_retry</span> <span class='hs-varid'>bdy_sent</span> <span class='hs-layout'>(</span><span class='hs-conid'>Right</span> <span class='hs-layout'>(</span><span class='hs-varid'>cd</span><span class='hs-layout'>,</span><span class='hs-varid'>rn</span><span class='hs-layout'>,</span><span class='hs-varid'>hdrs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span> <span class='hs-varid'>rqst</span> <span class='hs-keyglyph'>=</span>
<a name="line-137"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>matchResponse</span> <span class='hs-layout'>(</span><span class='hs-varid'>rqMethod</span> <span class='hs-varid'>rqst</span><span class='hs-layout'>)</span> <span class='hs-varid'>cd</span> <span class='hs-keyword'>of</span>
<a name="line-138"></a> <span class='hs-conid'>Continue</span>
<a name="line-139"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>not</span> <span class='hs-varid'>bdy_sent</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span> <span class='hs-comment'>{- Time to send the body -}</span>
<a name="line-140"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>conn</span> <span class='hs-layout'>(</span><span class='hs-varid'>rqBody</span> <span class='hs-varid'>rqst</span><span class='hs-layout'>)</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>either</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-varop'>.</span> <span class='hs-conid'>Left</span><span class='hs-layout'>)</span>
<a name="line-141"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-142"></a> <span class='hs-varid'>rsp</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getResponseHead</span> <span class='hs-varid'>conn</span>
<a name="line-143"></a> <span class='hs-varid'>switchResponse</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>allow_retry</span> <span class='hs-conid'>True</span> <span class='hs-varid'>rsp</span> <span class='hs-varid'>rqst</span><span class='hs-layout'>)</span>
<a name="line-144"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span> <span class='hs-comment'>{- keep waiting -}</span>
<a name="line-145"></a> <span class='hs-varid'>rsp</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getResponseHead</span> <span class='hs-varid'>conn</span>
<a name="line-146"></a> <span class='hs-varid'>switchResponse</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>allow_retry</span> <span class='hs-varid'>bdy_sent</span> <span class='hs-varid'>rsp</span> <span class='hs-varid'>rqst</span>
<a name="line-147"></a>
<a name="line-148"></a> <span class='hs-conid'>Retry</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span> <span class='hs-comment'>{- Request with "Expect" header failed.
<a name="line-149"></a> Trouble is the request contains Expects
<a name="line-150"></a> other than "100-Continue" -}</span>
<a name="line-151"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>conn</span> <span class='hs-layout'>(</span><span class='hs-layout'>(</span><span class='hs-varid'>buf_append</span> <span class='hs-varid'>bufferOps</span><span class='hs-layout'>)</span>
<a name="line-152"></a> <span class='hs-layout'>(</span><span class='hs-varid'>buf_fromStr</span> <span class='hs-varid'>bufferOps</span> <span class='hs-layout'>(</span><span class='hs-varid'>show</span> <span class='hs-varid'>rqst</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-153"></a> <span class='hs-layout'>(</span><span class='hs-varid'>rqBody</span> <span class='hs-varid'>rqst</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-154"></a> <span class='hs-varid'>rsp</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getResponseHead</span> <span class='hs-varid'>conn</span>
<a name="line-155"></a> <span class='hs-varid'>switchResponse</span> <span class='hs-varid'>conn</span> <span class='hs-conid'>False</span> <span class='hs-varid'>bdy_sent</span> <span class='hs-varid'>rsp</span> <span class='hs-varid'>rqst</span>
<a name="line-156"></a>
<a name="line-157"></a> <span class='hs-conid'>Done</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-158"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>findConnClose</span> <span class='hs-varid'>hdrs</span><span class='hs-layout'>)</span>
<a name="line-159"></a> <span class='hs-layout'>(</span><span class='hs-varid'>closeOnEnd</span> <span class='hs-varid'>conn</span> <span class='hs-conid'>True</span><span class='hs-layout'>)</span>
<a name="line-160"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-conid'>Right</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Response</span> <span class='hs-varid'>cd</span> <span class='hs-varid'>rn</span> <span class='hs-varid'>hdrs</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_empty</span> <span class='hs-varid'>bufferOps</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-161"></a>
<a name="line-162"></a> <span class='hs-conid'>DieHorribly</span> <span class='hs-varid'>str</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-163"></a> <span class='hs-varid'>close</span> <span class='hs-varid'>conn</span>
<a name="line-164"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>responseParseError</span> <span class='hs-str'>"Invalid response:"</span> <span class='hs-varid'>str</span><span class='hs-layout'>)</span>
<a name="line-165"></a> <span class='hs-conid'>ExpectEntity</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-166"></a> <span class='hs-varid'>r</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>fmapE</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-layout'>(</span><span class='hs-varid'>ftrs</span><span class='hs-layout'>,</span><span class='hs-varid'>bdy</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Right</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-varid'>cd</span> <span class='hs-varid'>rn</span> <span class='hs-layout'>(</span><span class='hs-varid'>hdrs</span><span class='hs-varop'>++</span><span class='hs-varid'>ftrs</span><span class='hs-layout'>)</span> <span class='hs-varid'>bdy</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span>
<a name="line-167"></a> <span class='hs-varid'>maybe</span> <span class='hs-layout'>(</span><span class='hs-varid'>maybe</span> <span class='hs-layout'>(</span><span class='hs-varid'>hopefulTransfer</span> <span class='hs-varid'>bo</span> <span class='hs-layout'>(</span><span class='hs-varid'>readLine</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-conid'>[]</span><span class='hs-layout'>)</span>
<a name="line-168"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>x</span> <span class='hs-keyglyph'>-></span>
<a name="line-169"></a> <span class='hs-varid'>readsOne</span> <span class='hs-layout'>(</span><span class='hs-varid'>linearTransfer</span> <span class='hs-layout'>(</span><span class='hs-varid'>readBlock</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-170"></a> <span class='hs-layout'>(</span><span class='hs-varid'>return</span><span class='hs-varop'>$</span><span class='hs-varid'>responseParseError</span> <span class='hs-str'>"unrecognized content-length value"</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-171"></a> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-172"></a> <span class='hs-varid'>cl</span><span class='hs-layout'>)</span>
<a name="line-173"></a> <span class='hs-layout'>(</span><span class='hs-varid'>ifChunked</span> <span class='hs-layout'>(</span><span class='hs-varid'>chunkedTransfer</span> <span class='hs-varid'>bo</span> <span class='hs-layout'>(</span><span class='hs-varid'>readLine</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>readBlock</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-174"></a> <span class='hs-layout'>(</span><span class='hs-varid'>uglyDeathTransfer</span> <span class='hs-str'>"sendHTTP"</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-175"></a> <span class='hs-varid'>tc</span>
<a name="line-176"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>r</span> <span class='hs-keyword'>of</span>
<a name="line-177"></a> <span class='hs-conid'>Left</span><span class='hs-layout'>{</span><span class='hs-layout'>}</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-178"></a> <span class='hs-varid'>close</span> <span class='hs-varid'>conn</span>
<a name="line-179"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>r</span>
<a name="line-180"></a> <span class='hs-conid'>Right</span> <span class='hs-layout'>(</span><span class='hs-conid'>Response</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-varid'>hs</span> <span class='hs-keyword'>_</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-181"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>findConnClose</span> <span class='hs-varid'>hs</span><span class='hs-layout'>)</span>
<a name="line-182"></a> <span class='hs-layout'>(</span><span class='hs-varid'>closeOnEnd</span> <span class='hs-varid'>conn</span> <span class='hs-conid'>True</span><span class='hs-layout'>)</span>
<a name="line-183"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>r</span>
<a name="line-184"></a>
<a name="line-185"></a> <span class='hs-keyword'>where</span>
<a name="line-186"></a> <span class='hs-varid'>tc</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>lookupHeader</span> <span class='hs-conid'>HdrTransferEncoding</span> <span class='hs-varid'>hdrs</span>
<a name="line-187"></a> <span class='hs-varid'>cl</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>lookupHeader</span> <span class='hs-conid'>HdrContentLength</span> <span class='hs-varid'>hdrs</span>
<a name="line-188"></a> <span class='hs-varid'>bo</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>bufferOps</span>
<a name="line-189"></a>
<a name="line-190"></a><a name="getResponseHead"></a><span class='hs-comment'>-- reads and parses headers</span>
<a name="line-191"></a><span class='hs-definition'>getResponseHead</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-conid'>ResponseData</span><span class='hs-layout'>)</span>
<a name="line-192"></a><span class='hs-definition'>getResponseHead</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>=</span>
<a name="line-193"></a> <span class='hs-varid'>fmapE</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>es</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>parseResponseHead</span> <span class='hs-layout'>(</span><span class='hs-varid'>map</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_toStr</span> <span class='hs-varid'>bufferOps</span><span class='hs-layout'>)</span> <span class='hs-varid'>es</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-194"></a> <span class='hs-layout'>(</span><span class='hs-varid'>readTillEmpty1</span> <span class='hs-varid'>bufferOps</span> <span class='hs-layout'>(</span><span class='hs-varid'>readLine</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-195"></a>
<a name="line-196"></a><a name="receiveHTTP"></a><span class='hs-comment'>-- | @receiveHTTP hStream@ reads a 'Request' from the 'HandleStream' @hStream@</span>
<a name="line-197"></a><span class='hs-definition'>receiveHTTP</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>bufTy</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufTy</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-layout'>(</span><span class='hs-conid'>Request</span> <span class='hs-varid'>bufTy</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-198"></a><span class='hs-definition'>receiveHTTP</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>getRequestHead</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>either</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-varop'>.</span> <span class='hs-conid'>Left</span><span class='hs-layout'>)</span> <span class='hs-varid'>processRequest</span>
<a name="line-199"></a> <span class='hs-keyword'>where</span>
<a name="line-200"></a> <span class='hs-comment'>-- reads and parses headers</span>
<a name="line-201"></a> <span class='hs-varid'>getRequestHead</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-conid'>RequestData</span><span class='hs-layout'>)</span>
<a name="line-202"></a> <span class='hs-varid'>getRequestHead</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-203"></a> <span class='hs-varid'>fmapE</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>es</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>parseRequestHead</span> <span class='hs-layout'>(</span><span class='hs-varid'>map</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_toStr</span> <span class='hs-varid'>bufferOps</span><span class='hs-layout'>)</span> <span class='hs-varid'>es</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-204"></a> <span class='hs-layout'>(</span><span class='hs-varid'>readTillEmpty1</span> <span class='hs-varid'>bufferOps</span> <span class='hs-layout'>(</span><span class='hs-varid'>readLine</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-205"></a>
<a name="line-206"></a> <span class='hs-varid'>processRequest</span> <span class='hs-layout'>(</span><span class='hs-varid'>rm</span><span class='hs-layout'>,</span><span class='hs-varid'>uri</span><span class='hs-layout'>,</span><span class='hs-varid'>hdrs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span>
<a name="line-207"></a> <span class='hs-varid'>fmapE</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-layout'>(</span><span class='hs-varid'>ftrs</span><span class='hs-layout'>,</span><span class='hs-varid'>bdy</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Right</span> <span class='hs-layout'>(</span><span class='hs-conid'>Request</span> <span class='hs-varid'>uri</span> <span class='hs-varid'>rm</span> <span class='hs-layout'>(</span><span class='hs-varid'>hdrs</span><span class='hs-varop'>++</span><span class='hs-varid'>ftrs</span><span class='hs-layout'>)</span> <span class='hs-varid'>bdy</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span>
<a name="line-208"></a> <span class='hs-varid'>maybe</span>
<a name="line-209"></a> <span class='hs-layout'>(</span><span class='hs-varid'>maybe</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-conid'>Right</span> <span class='hs-layout'>(</span><span class='hs-conid'>[]</span><span class='hs-layout'>,</span> <span class='hs-varid'>buf_empty</span> <span class='hs-varid'>bo</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span> <span class='hs-comment'>-- hopefulTransfer ""</span>
<a name="line-210"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>x</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>readsOne</span> <span class='hs-layout'>(</span><span class='hs-varid'>linearTransfer</span> <span class='hs-layout'>(</span><span class='hs-varid'>readBlock</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-211"></a> <span class='hs-layout'>(</span><span class='hs-varid'>return</span><span class='hs-varop'>$</span><span class='hs-varid'>responseParseError</span> <span class='hs-str'>"unrecognized Content-Length value"</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-212"></a> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-213"></a>
<a name="line-214"></a> <span class='hs-varid'>cl</span><span class='hs-layout'>)</span>
<a name="line-215"></a> <span class='hs-layout'>(</span><span class='hs-varid'>ifChunked</span> <span class='hs-layout'>(</span><span class='hs-varid'>chunkedTransfer</span> <span class='hs-varid'>bo</span> <span class='hs-layout'>(</span><span class='hs-varid'>readLine</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>readBlock</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-216"></a> <span class='hs-layout'>(</span><span class='hs-varid'>uglyDeathTransfer</span> <span class='hs-str'>"receiveHTTP"</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-217"></a> <span class='hs-varid'>tc</span>
<a name="line-218"></a> <span class='hs-keyword'>where</span>
<a name="line-219"></a> <span class='hs-comment'>-- FIXME : Also handle 100-continue.</span>
<a name="line-220"></a> <span class='hs-varid'>tc</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>lookupHeader</span> <span class='hs-conid'>HdrTransferEncoding</span> <span class='hs-varid'>hdrs</span>
<a name="line-221"></a> <span class='hs-varid'>cl</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>lookupHeader</span> <span class='hs-conid'>HdrContentLength</span> <span class='hs-varid'>hdrs</span>
<a name="line-222"></a> <span class='hs-varid'>bo</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>bufferOps</span>
<a name="line-223"></a>
<a name="line-224"></a><a name="respondHTTP"></a><span class='hs-comment'>-- | @respondHTTP hStream httpResponse@ transmits an HTTP 'Response' over</span>
<a name="line-225"></a><span class='hs-comment'>-- the 'HandleStream' @hStream@. It could be used to implement simple web</span>
<a name="line-226"></a><span class='hs-comment'>-- server interactions, performing the dual role to 'sendHTTP'.</span>
<a name="line-227"></a><span class='hs-definition'>respondHTTP</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Response</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-228"></a><span class='hs-definition'>respondHTTP</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>rsp</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-229"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>conn</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_fromStr</span> <span class='hs-varid'>bufferOps</span> <span class='hs-varop'>$</span> <span class='hs-varid'>show</span> <span class='hs-varid'>rsp</span><span class='hs-layout'>)</span>
<a name="line-230"></a> <span class='hs-comment'>-- write body immediately, don't wait for 100 CONTINUE</span>
<a name="line-231"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>conn</span> <span class='hs-layout'>(</span><span class='hs-varid'>rspBody</span> <span class='hs-varid'>rsp</span><span class='hs-layout'>)</span>
<a name="line-232"></a> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-233"></a>
<a name="line-234"></a><span class='hs-comment'>------------------------------------------------------------------------------</span>
<a name="line-235"></a>
<a name="line-236"></a><a name="headerName"></a><span class='hs-definition'>headerName</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>String</span>
<a name="line-237"></a><span class='hs-definition'>headerName</span> <span class='hs-varid'>x</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>map</span> <span class='hs-varid'>toLower</span> <span class='hs-layout'>(</span><span class='hs-varid'>trim</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-238"></a>
<a name="line-239"></a><a name="ifChunked"></a><span class='hs-definition'>ifChunked</span> <span class='hs-keyglyph'>::</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>a</span>
<a name="line-240"></a><span class='hs-definition'>ifChunked</span> <span class='hs-varid'>a</span> <span class='hs-varid'>b</span> <span class='hs-varid'>s</span> <span class='hs-keyglyph'>=</span>
<a name="line-241"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>headerName</span> <span class='hs-varid'>s</span> <span class='hs-keyword'>of</span>
<a name="line-242"></a> <span class='hs-str'>"chunked"</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>a</span>
<a name="line-243"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>b</span>
<a name="line-244"></a>
</pre></body>
</html>
