<?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>Data/Conduit.hs</title>
<link type='text/css' rel='stylesheet' href='hscolour.css' />
</head>
<body>
<pre><a name="line-1"></a><span class='hs-comment'>{-# LANGUAGE FlexibleContexts #-}</span>
<a name="line-2"></a><span class='hs-comment'>{-# LANGUAGE FlexibleInstances #-}</span>
<a name="line-3"></a><span class='hs-comment'>{-# LANGUAGE MultiParamTypeClasses #-}</span>
<a name="line-4"></a><span class='hs-comment'>{-# LANGUAGE UndecidableInstances #-}</span>
<a name="line-5"></a><span class='hs-comment'>{-# LANGUAGE DeriveDataTypeable #-}</span>
<a name="line-6"></a><span class='hs-comment'>-- | The main module, exporting types, utility functions, and fuse and connect</span>
<a name="line-7"></a><span class='hs-comment'>-- operators.</span>
<a name="line-8"></a><span class='hs-keyword'>module</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span>
<a name="line-9"></a> <span class='hs-layout'>(</span> <span class='hs-comment'>-- * Types</span>
<a name="line-10"></a> <span class='hs-comment'>-- | The three core types to this package are 'Source' (the data</span>
<a name="line-11"></a> <span class='hs-comment'>-- producer), 'Sink' (the data consumer), and 'Conduit' (the data</span>
<a name="line-12"></a> <span class='hs-comment'>-- transformer). For all three types, a result will provide the next</span>
<a name="line-13"></a> <span class='hs-comment'>-- value to be used. For example, the @Open@ constructor includes a new</span>
<a name="line-14"></a> <span class='hs-comment'>-- @Source@ in it. This leads to the main invariant for all conduit code:</span>
<a name="line-15"></a> <span class='hs-comment'>-- these three types may /never/ be reused. While some specific values</span>
<a name="line-16"></a> <span class='hs-comment'>-- may work fine with reuse, the result is generally unpredictable and</span>
<a name="line-17"></a> <span class='hs-comment'>-- should no be relied upon.</span>
<a name="line-18"></a> <span class='hs-comment'>--</span>
<a name="line-19"></a> <span class='hs-comment'>-- The user-facing API provided by the connect and fuse operators</span>
<a name="line-20"></a> <span class='hs-comment'>-- automatically addresses the low level details of pulling, pushing, and</span>
<a name="line-21"></a> <span class='hs-comment'>-- closing, and there should rarely be need to perform these actions in</span>
<a name="line-22"></a> <span class='hs-comment'>-- user code.</span>
<a name="line-23"></a>
<a name="line-24"></a> <span class='hs-comment'>-- ** Source</span>
<a name="line-25"></a> <span class='hs-keyword'>module</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span><span class='hs-varop'>.</span><span class='hs-conid'>Source</span>
<a name="line-26"></a> <span class='hs-comment'>-- *** Buffering</span>
<a name="line-27"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>BufferedSource</span>
<a name="line-28"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>bufferSource</span>
<a name="line-29"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>unbufferSource</span>
<a name="line-30"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>bsourceClose</span>
<a name="line-31"></a> <span class='hs-comment'>-- *** Unifying</span>
<a name="line-32"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>IsSource</span>
<a name="line-33"></a> <span class='hs-comment'>-- ** Sink</span>
<a name="line-34"></a> <span class='hs-layout'>,</span> <span class='hs-keyword'>module</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span><span class='hs-varop'>.</span><span class='hs-conid'>Sink</span>
<a name="line-35"></a> <span class='hs-comment'>-- ** Conduit</span>
<a name="line-36"></a> <span class='hs-layout'>,</span> <span class='hs-keyword'>module</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span>
<a name="line-37"></a> <span class='hs-layout'>,</span> <span class='hs-comment'>-- * Connect/fuse operators</span>
<a name="line-38"></a> <span class='hs-layout'>(</span><span class='hs-varop'>$$</span><span class='hs-layout'>)</span>
<a name="line-39"></a> <span class='hs-layout'>,</span> <span class='hs-layout'>(</span><span class='hs-varop'>$=</span><span class='hs-layout'>)</span>
<a name="line-40"></a> <span class='hs-layout'>,</span> <span class='hs-layout'>(</span><span class='hs-varop'>=$</span><span class='hs-layout'>)</span>
<a name="line-41"></a> <span class='hs-layout'>,</span> <span class='hs-layout'>(</span><span class='hs-varop'>=$=</span><span class='hs-layout'>)</span>
<a name="line-42"></a> <span class='hs-comment'>-- * Utility functions</span>
<a name="line-43"></a> <span class='hs-comment'>-- ** Source</span>
<a name="line-44"></a> <span class='hs-layout'>,</span> <span class='hs-keyword'>module</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Util</span><span class='hs-varop'>.</span><span class='hs-conid'>Source</span>
<a name="line-45"></a> <span class='hs-comment'>-- ** Sink</span>
<a name="line-46"></a> <span class='hs-layout'>,</span> <span class='hs-keyword'>module</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Util</span><span class='hs-varop'>.</span><span class='hs-conid'>Sink</span>
<a name="line-47"></a> <span class='hs-comment'>-- ** Conduit</span>
<a name="line-48"></a> <span class='hs-layout'>,</span> <span class='hs-keyword'>module</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Util</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span>
<a name="line-49"></a> <span class='hs-comment'>-- * Flushing</span>
<a name="line-50"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>Flush</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-51"></a> <span class='hs-comment'>-- * Convenience re-exports</span>
<a name="line-52"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>ResourceT</span>
<a name="line-53"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>Resource</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-54"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>ResourceIO</span>
<a name="line-55"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>ResourceUnsafeIO</span>
<a name="line-56"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>runResourceT</span>
<a name="line-57"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>ResourceThrow</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-58"></a> <span class='hs-layout'>)</span> <span class='hs-keyword'>where</span>
<a name="line-59"></a>
<a name="line-60"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Applicative</span> <span class='hs-layout'>(</span><span class='hs-layout'>(</span><span class='hs-varop'><$></span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-61"></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'>liftM</span><span class='hs-layout'>)</span>
<a name="line-62"></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-varop'>.</span><span class='hs-conid'>Trans</span><span class='hs-varop'>.</span><span class='hs-conid'>Resource</span>
<a name="line-63"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span><span class='hs-varop'>.</span><span class='hs-conid'>Source</span>
<a name="line-64"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Util</span><span class='hs-varop'>.</span><span class='hs-conid'>Source</span>
<a name="line-65"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span><span class='hs-varop'>.</span><span class='hs-conid'>Sink</span>
<a name="line-66"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Util</span><span class='hs-varop'>.</span><span class='hs-conid'>Sink</span>
<a name="line-67"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span>
<a name="line-68"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span><span class='hs-varop'>.</span><span class='hs-conid'>Util</span><span class='hs-varop'>.</span><span class='hs-conid'>Conduit</span>
<a name="line-69"></a>
<a name="line-70"></a><span class='hs-comment'>-- $typeOverview</span>
<a name="line-71"></a>
<a name="line-72"></a><span class='hs-keyword'>infixr</span> <span class='hs-num'>0</span> <span class='hs-varop'>$$</span>
<a name="line-73"></a>
<a name="line-74"></a><a name="$$"></a><span class='hs-comment'>-- | The connect operator, which pulls data from a source and pushes to a sink.</span>
<a name="line-75"></a><span class='hs-comment'>-- There are three ways this process can terminate:</span>
<a name="line-76"></a><span class='hs-comment'>--</span>
<a name="line-77"></a><span class='hs-comment'>-- 1. In the case of a @SinkNoData@ constructor, the source is not opened at</span>
<a name="line-78"></a><span class='hs-comment'>-- all, and the output value is returned immediately.</span>
<a name="line-79"></a><span class='hs-comment'>--</span>
<a name="line-80"></a><span class='hs-comment'>-- 2. The sink returns @Done@. If the input was a @BufferedSource@, any</span>
<a name="line-81"></a><span class='hs-comment'>-- leftover input is put in the buffer. For a normal @Source@, the leftover</span>
<a name="line-82"></a><span class='hs-comment'>-- value is discarded, and the source is closed.</span>
<a name="line-83"></a><span class='hs-comment'>--</span>
<a name="line-84"></a><span class='hs-comment'>-- 3. The source return @Closed@, in which case the sink is closed.</span>
<a name="line-85"></a><span class='hs-comment'>--</span>
<a name="line-86"></a><span class='hs-comment'>-- Note that this function will automatically close any @Source@s, but will not</span>
<a name="line-87"></a><span class='hs-comment'>-- close any @BufferedSource@s, allowing them to be reused.</span>
<a name="line-88"></a><span class='hs-comment'>--</span>
<a name="line-89"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-90"></a><span class='hs-layout'>(</span><span class='hs-varop'>$$</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>::</span> <span class='hs-layout'>(</span><span class='hs-conid'>IsSource</span> <span class='hs-varid'>src</span><span class='hs-layout'>,</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=></span> <span class='hs-varid'>src</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Sink</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-91"></a><span class='hs-layout'>(</span><span class='hs-varop'>$$</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>connect</span>
<a name="line-92"></a><span class='hs-comment'>{-# INLINE ($$) #-}</span>
<a name="line-93"></a>
<a name="line-94"></a><span class='hs-comment'>-- | A typeclass allowing us to unify operators for 'Source' and</span>
<a name="line-95"></a><span class='hs-comment'>-- 'BufferedSource'.</span>
<a name="line-96"></a><span class='hs-comment'>--</span>
<a name="line-97"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-98"></a><span class='hs-keyword'>class</span> <span class='hs-conid'>IsSource</span> <span class='hs-varid'>src</span> <span class='hs-keyword'>where</span>
<a name="line-99"></a> <span class='hs-varid'>connect</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-varid'>src</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Sink</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-100"></a> <span class='hs-varid'>fuseLeft</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-varid'>src</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-101"></a>
<a name="line-102"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>IsSource</span> <span class='hs-conid'>Source</span> <span class='hs-keyword'>where</span>
<a name="line-103"></a> <span class='hs-varid'>connect</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>normalConnect</span>
<a name="line-104"></a> <span class='hs-comment'>{-# INLINE connect #-}</span>
<a name="line-105"></a> <span class='hs-varid'>fuseLeft</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>normalFuseLeft</span>
<a name="line-106"></a> <span class='hs-comment'>{-# INLINE fuseLeft #-}</span>
<a name="line-107"></a>
<a name="line-108"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>IsSource</span> <span class='hs-conid'>BufferedSource</span> <span class='hs-keyword'>where</span>
<a name="line-109"></a> <span class='hs-varid'>connect</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>bufferedConnect</span>
<a name="line-110"></a> <span class='hs-comment'>{-# INLINE connect #-}</span>
<a name="line-111"></a> <span class='hs-varid'>fuseLeft</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>bufferedFuseLeft</span>
<a name="line-112"></a> <span class='hs-comment'>{-# INLINE fuseLeft #-}</span>
<a name="line-113"></a>
<a name="line-114"></a><a name="normalConnect"></a><span class='hs-definition'>normalConnect</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Sink</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-115"></a><span class='hs-definition'>normalConnect</span> <span class='hs-keyword'>_</span> <span class='hs-layout'>(</span><span class='hs-conid'>SinkNoData</span> <span class='hs-varid'>output</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-varid'>output</span>
<a name="line-116"></a><span class='hs-definition'>normalConnect</span> <span class='hs-varid'>src0</span> <span class='hs-layout'>(</span><span class='hs-conid'>SinkLift</span> <span class='hs-varid'>msink</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>msink</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>normalConnect</span> <span class='hs-varid'>src0</span>
<a name="line-117"></a><span class='hs-definition'>normalConnect</span> <span class='hs-varid'>src0</span> <span class='hs-layout'>(</span><span class='hs-conid'>SinkData</span> <span class='hs-varid'>push0</span> <span class='hs-varid'>close0</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span>
<a name="line-118"></a> <span class='hs-varid'>connect'</span> <span class='hs-varid'>src0</span> <span class='hs-varid'>push0</span> <span class='hs-varid'>close0</span>
<a name="line-119"></a> <span class='hs-keyword'>where</span>
<a name="line-120"></a> <span class='hs-varid'>connect'</span> <span class='hs-varid'>src</span> <span class='hs-varid'>push</span> <span class='hs-varid'>close</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-121"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>sourcePull</span> <span class='hs-varid'>src</span>
<a name="line-122"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-123"></a> <span class='hs-conid'>Closed</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-124"></a> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>close</span>
<a name="line-125"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>res'</span>
<a name="line-126"></a> <span class='hs-conid'>Open</span> <span class='hs-varid'>src'</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-127"></a> <span class='hs-varid'>mres</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>push</span> <span class='hs-varid'>a</span>
<a name="line-128"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mres</span> <span class='hs-keyword'>of</span>
<a name="line-129"></a> <span class='hs-conid'>Done</span> <span class='hs-sel'>_leftover</span> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-130"></a> <span class='hs-varid'>sourceClose</span> <span class='hs-varid'>src'</span>
<a name="line-131"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>res'</span>
<a name="line-132"></a> <span class='hs-conid'>Processing</span> <span class='hs-varid'>push'</span> <span class='hs-varid'>close'</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>connect'</span> <span class='hs-varid'>src'</span> <span class='hs-varid'>push'</span> <span class='hs-varid'>close'</span>
<a name="line-133"></a>
<a name="line-134"></a><a name="FuseLeftState"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>FuseLeftState</span> <span class='hs-varid'>src</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>output</span> <span class='hs-keyglyph'>=</span>
<a name="line-135"></a> <span class='hs-conid'>FLClosed</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>output</span><span class='hs-keyglyph'>]</span>
<a name="line-136"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src</span> <span class='hs-varid'>conduit</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>output</span><span class='hs-keyglyph'>]</span>
<a name="line-137"></a>
<a name="line-138"></a><span class='hs-keyword'>infixl</span> <span class='hs-num'>1</span> <span class='hs-varop'>$=</span>
<a name="line-139"></a>
<a name="line-140"></a><a name="$="></a><span class='hs-comment'>-- | Left fuse, combining a source and a conduit together into a new source.</span>
<a name="line-141"></a><span class='hs-comment'>--</span>
<a name="line-142"></a><span class='hs-comment'>-- Note that any @Source@ passed in will be automatically closed, while a</span>
<a name="line-143"></a><span class='hs-comment'>-- @BufferedSource@ will be left open.</span>
<a name="line-144"></a><span class='hs-comment'>--</span>
<a name="line-145"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-146"></a><span class='hs-layout'>(</span><span class='hs-varop'>$=</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>::</span> <span class='hs-layout'>(</span><span class='hs-conid'>IsSource</span> <span class='hs-varid'>src</span><span class='hs-layout'>,</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span><span class='hs-layout'>)</span>
<a name="line-147"></a> <span class='hs-keyglyph'>=></span> <span class='hs-varid'>src</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span>
<a name="line-148"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-149"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-150"></a><span class='hs-layout'>(</span><span class='hs-varop'>$=</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>fuseLeft</span>
<a name="line-151"></a><span class='hs-comment'>{-# INLINE ($=) #-}</span>
<a name="line-152"></a>
<a name="line-153"></a><a name="normalFuseLeft"></a><span class='hs-definition'>normalFuseLeft</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-154"></a><span class='hs-definition'>normalFuseLeft</span> <span class='hs-varid'>src0</span> <span class='hs-varid'>conduit0</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Source</span>
<a name="line-155"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>sourcePull</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>pull</span> <span class='hs-varop'>$</span> <span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src0</span> <span class='hs-varid'>conduit0</span> <span class='hs-conid'>[]</span>
<a name="line-156"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sourceClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-157"></a> <span class='hs-layout'>}</span>
<a name="line-158"></a> <span class='hs-keyword'>where</span>
<a name="line-159"></a> <span class='hs-varid'>mkSrc</span> <span class='hs-varid'>state</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Source</span> <span class='hs-layout'>(</span><span class='hs-varid'>pull</span> <span class='hs-varid'>state</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>close</span> <span class='hs-varid'>state</span><span class='hs-layout'>)</span>
<a name="line-160"></a> <span class='hs-varid'>pull</span> <span class='hs-varid'>state'</span> <span class='hs-keyglyph'>=</span>
<a name="line-161"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>state'</span> <span class='hs-keyword'>of</span>
<a name="line-162"></a> <span class='hs-conid'>FLClosed</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span>
<a name="line-163"></a> <span class='hs-conid'>FLClosed</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-164"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLClosed</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-165"></a> <span class='hs-varid'>x</span>
<a name="line-166"></a> <span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src</span> <span class='hs-varid'>conduit</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-167"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-168"></a> <span class='hs-varid'>x</span>
<a name="line-169"></a> <span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src</span> <span class='hs-varid'>conduit</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-170"></a> <span class='hs-varid'>mres</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>sourcePull</span> <span class='hs-varid'>src</span>
<a name="line-171"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mres</span> <span class='hs-keyword'>of</span>
<a name="line-172"></a> <span class='hs-conid'>Closed</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-173"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitClose</span> <span class='hs-varid'>conduit</span>
<a name="line-174"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-175"></a> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span>
<a name="line-176"></a> <span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-177"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLClosed</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-178"></a> <span class='hs-varid'>x</span>
<a name="line-179"></a> <span class='hs-conid'>Open</span> <span class='hs-varid'>src''</span> <span class='hs-varid'>input</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-180"></a> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPush</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>input</span>
<a name="line-181"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res'</span> <span class='hs-keyword'>of</span>
<a name="line-182"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>conduit'</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span>
<a name="line-183"></a> <span class='hs-varid'>pull</span> <span class='hs-varop'>$</span> <span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src''</span> <span class='hs-varid'>conduit'</span> <span class='hs-conid'>[]</span>
<a name="line-184"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>conduit'</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-185"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src''</span> <span class='hs-varid'>conduit'</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-186"></a> <span class='hs-varid'>x</span>
<a name="line-187"></a> <span class='hs-conid'>Finished</span> <span class='hs-sel'>_leftover</span> <span class='hs-varid'>output</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-188"></a> <span class='hs-varid'>sourceClose</span> <span class='hs-varid'>src''</span>
<a name="line-189"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>output</span> <span class='hs-keyword'>of</span>
<a name="line-190"></a> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span>
<a name="line-191"></a> <span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-192"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLClosed</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-193"></a> <span class='hs-varid'>x</span>
<a name="line-194"></a> <span class='hs-varid'>close</span> <span class='hs-varid'>state</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-195"></a> <span class='hs-comment'>-- See comment on bufferedFuseLeft for why we need to have the</span>
<a name="line-196"></a> <span class='hs-comment'>-- following check</span>
<a name="line-197"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>state</span> <span class='hs-keyword'>of</span>
<a name="line-198"></a> <span class='hs-conid'>FLClosed</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-199"></a> <span class='hs-conid'>FLOpen</span> <span class='hs-varid'>src'</span> <span class='hs-layout'>(</span><span class='hs-conid'>Conduit</span> <span class='hs-keyword'>_</span> <span class='hs-varid'>closeC</span><span class='hs-layout'>)</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-200"></a> <span class='hs-sel'>_ignored</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>closeC</span>
<a name="line-201"></a> <span class='hs-varid'>sourceClose</span> <span class='hs-varid'>src'</span>
<a name="line-202"></a>
<a name="line-203"></a><span class='hs-keyword'>infixr</span> <span class='hs-num'>0</span> <span class='hs-varop'>=$</span>
<a name="line-204"></a>
<a name="line-205"></a><a name="=$"></a><span class='hs-comment'>-- | Right fuse, combining a conduit and a sink together into a new sink.</span>
<a name="line-206"></a><span class='hs-comment'>--</span>
<a name="line-207"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-208"></a><span class='hs-layout'>(</span><span class='hs-varop'>=$</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Sink</span> <span class='hs-varid'>b</span> <span class='hs-varid'>m</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Sink</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>c</span>
<a name="line-209"></a><span class='hs-keyword'>_</span> <span class='hs-varop'>=$</span> <span class='hs-conid'>SinkNoData</span> <span class='hs-varid'>res</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>SinkNoData</span> <span class='hs-varid'>res</span>
<a name="line-210"></a><a name="conduit"></a><span class='hs-definition'>conduit</span> <span class='hs-varop'>=$</span> <span class='hs-conid'>SinkLift</span> <span class='hs-varid'>msink</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>SinkLift</span> <span class='hs-layout'>(</span><span class='hs-varid'>liftM</span> <span class='hs-layout'>(</span><span class='hs-varid'>conduit</span> <span class='hs-varop'>=$</span><span class='hs-layout'>)</span> <span class='hs-varid'>msink</span><span class='hs-layout'>)</span>
<a name="line-211"></a><a name="conduitOrig"></a><span class='hs-definition'>conduitOrig</span> <span class='hs-varop'>=$</span> <span class='hs-conid'>SinkData</span> <span class='hs-varid'>pushI0</span> <span class='hs-varid'>closeI0</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>SinkData</span>
<a name="line-212"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>sinkPush</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>push</span> <span class='hs-varid'>pushI0</span> <span class='hs-varid'>closeI0</span> <span class='hs-varid'>conduitOrig</span>
<a name="line-213"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sinkClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>close</span> <span class='hs-varid'>pushI0</span> <span class='hs-varid'>closeI0</span> <span class='hs-varid'>conduitOrig</span>
<a name="line-214"></a> <span class='hs-layout'>}</span>
<a name="line-215"></a> <span class='hs-keyword'>where</span>
<a name="line-216"></a> <span class='hs-varid'>push</span> <span class='hs-varid'>pushI</span> <span class='hs-varid'>closeI</span> <span class='hs-varid'>conduit0</span> <span class='hs-varid'>cinput</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-217"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPush</span> <span class='hs-varid'>conduit0</span> <span class='hs-varid'>cinput</span>
<a name="line-218"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-219"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>conduit'</span> <span class='hs-varid'>sinput</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-220"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>loop</span> <span class='hs-varid'>p</span> <span class='hs-varid'>c</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-conid'>Processing</span> <span class='hs-layout'>(</span><span class='hs-varid'>push</span> <span class='hs-varid'>p</span> <span class='hs-varid'>c</span> <span class='hs-varid'>conduit'</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>close</span> <span class='hs-varid'>p</span> <span class='hs-varid'>c</span> <span class='hs-varid'>conduit'</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-221"></a> <span class='hs-varid'>loop</span> <span class='hs-varid'>p</span> <span class='hs-keyword'>_</span> <span class='hs-layout'>(</span><span class='hs-varid'>i</span><span class='hs-conop'>:</span><span class='hs-varid'>is</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-222"></a> <span class='hs-varid'>mres</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>p</span> <span class='hs-varid'>i</span>
<a name="line-223"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mres</span> <span class='hs-keyword'>of</span>
<a name="line-224"></a> <span class='hs-conid'>Processing</span> <span class='hs-varid'>p'</span> <span class='hs-varid'>c'</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>loop</span> <span class='hs-varid'>p'</span> <span class='hs-varid'>c'</span> <span class='hs-varid'>is</span>
<a name="line-225"></a> <span class='hs-conid'>Done</span> <span class='hs-sel'>_sleftover</span> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-226"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitClose</span> <span class='hs-varid'>conduit'</span>
<a name="line-227"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Done</span> <span class='hs-conid'>Nothing</span> <span class='hs-varid'>res'</span>
<a name="line-228"></a> <span class='hs-varid'>loop</span> <span class='hs-varid'>pushI</span> <span class='hs-varid'>closeI</span> <span class='hs-varid'>sinput</span>
<a name="line-229"></a> <span class='hs-conid'>Finished</span> <span class='hs-varid'>cleftover</span> <span class='hs-varid'>sinput</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-230"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>loop</span> <span class='hs-keyword'>_</span> <span class='hs-varid'>c</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>c</span>
<a name="line-231"></a> <span class='hs-varid'>loop</span> <span class='hs-varid'>p</span> <span class='hs-keyword'>_</span> <span class='hs-layout'>(</span><span class='hs-varid'>i</span><span class='hs-conop'>:</span><span class='hs-varid'>is</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-232"></a> <span class='hs-varid'>mres</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>p</span> <span class='hs-varid'>i</span>
<a name="line-233"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mres</span> <span class='hs-keyword'>of</span>
<a name="line-234"></a> <span class='hs-conid'>Processing</span> <span class='hs-varid'>p'</span> <span class='hs-varid'>c'</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>loop</span> <span class='hs-varid'>p'</span> <span class='hs-varid'>c'</span> <span class='hs-varid'>is</span>
<a name="line-235"></a> <span class='hs-conid'>Done</span> <span class='hs-sel'>_sleftover</span> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>res'</span>
<a name="line-236"></a> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>loop</span> <span class='hs-varid'>pushI</span> <span class='hs-varid'>closeI</span> <span class='hs-varid'>sinput</span>
<a name="line-237"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Done</span> <span class='hs-varid'>cleftover</span> <span class='hs-varid'>res'</span>
<a name="line-238"></a> <span class='hs-varid'>close</span> <span class='hs-varid'>pushI</span> <span class='hs-varid'>closeI</span> <span class='hs-varid'>conduit</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-239"></a> <span class='hs-varid'>sinput</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitClose</span> <span class='hs-varid'>conduit</span>
<a name="line-240"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>loop</span> <span class='hs-keyword'>_</span> <span class='hs-varid'>c</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>c</span>
<a name="line-241"></a> <span class='hs-varid'>loop</span> <span class='hs-varid'>p</span> <span class='hs-keyword'>_</span> <span class='hs-layout'>(</span><span class='hs-varid'>i</span><span class='hs-conop'>:</span><span class='hs-varid'>is</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-242"></a> <span class='hs-varid'>mres</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>p</span> <span class='hs-varid'>i</span>
<a name="line-243"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mres</span> <span class='hs-keyword'>of</span>
<a name="line-244"></a> <span class='hs-conid'>Processing</span> <span class='hs-varid'>p'</span> <span class='hs-varid'>c'</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>loop</span> <span class='hs-varid'>p'</span> <span class='hs-varid'>c'</span> <span class='hs-varid'>is</span>
<a name="line-245"></a> <span class='hs-conid'>Done</span> <span class='hs-sel'>_sleftover</span> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>res'</span>
<a name="line-246"></a> <span class='hs-varid'>loop</span> <span class='hs-varid'>pushI</span> <span class='hs-varid'>closeI</span> <span class='hs-varid'>sinput</span>
<a name="line-247"></a>
<a name="line-248"></a><span class='hs-keyword'>infixr</span> <span class='hs-num'>0</span> <span class='hs-varop'>=$=</span>
<a name="line-249"></a>
<a name="line-250"></a><a name="=$="></a><span class='hs-comment'>-- | Middle fuse, combining two conduits together into a new conduit.</span>
<a name="line-251"></a><span class='hs-comment'>--</span>
<a name="line-252"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-253"></a><span class='hs-layout'>(</span><span class='hs-varop'>=$=</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>b</span> <span class='hs-varid'>m</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>c</span>
<a name="line-254"></a><a name="outerOrig"></a><span class='hs-definition'>outerOrig</span> <span class='hs-varop'>=$=</span> <span class='hs-varid'>innerOrig</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Conduit</span>
<a name="line-255"></a> <span class='hs-layout'>(</span><span class='hs-varid'>pushF</span> <span class='hs-varid'>outerOrig</span> <span class='hs-varid'>innerOrig</span><span class='hs-layout'>)</span>
<a name="line-256"></a> <span class='hs-layout'>(</span><span class='hs-varid'>closeF</span> <span class='hs-varid'>outerOrig</span> <span class='hs-varid'>innerOrig</span><span class='hs-layout'>)</span>
<a name="line-257"></a> <span class='hs-keyword'>where</span>
<a name="line-258"></a> <span class='hs-varid'>pushF</span> <span class='hs-varid'>outer0</span> <span class='hs-varid'>inner0</span> <span class='hs-varid'>inputO</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-259"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPush</span> <span class='hs-varid'>outer0</span> <span class='hs-varid'>inputO</span>
<a name="line-260"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-261"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>outer</span> <span class='hs-varid'>inputI</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-262"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>loop</span> <span class='hs-varid'>inner</span> <span class='hs-conid'>[]</span> <span class='hs-varid'>front</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Producing</span>
<a name="line-263"></a> <span class='hs-layout'>(</span><span class='hs-conid'>Conduit</span> <span class='hs-layout'>(</span><span class='hs-varid'>pushF</span> <span class='hs-varid'>outer</span> <span class='hs-varid'>inner</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>closeF</span> <span class='hs-varid'>outer</span> <span class='hs-varid'>inner</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-264"></a> <span class='hs-layout'>(</span><span class='hs-varid'>front</span> <span class='hs-conid'>[]</span><span class='hs-layout'>)</span>
<a name="line-265"></a> <span class='hs-varid'>loop</span> <span class='hs-varid'>inner</span> <span class='hs-layout'>(</span><span class='hs-varid'>i</span><span class='hs-conop'>:</span><span class='hs-varid'>is</span><span class='hs-layout'>)</span> <span class='hs-varid'>front</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-266"></a> <span class='hs-varid'>resI</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPush</span> <span class='hs-varid'>inner</span> <span class='hs-varid'>i</span>
<a name="line-267"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>resI</span> <span class='hs-keyword'>of</span>
<a name="line-268"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>loop</span>
<a name="line-269"></a> <span class='hs-varid'>conduit</span>
<a name="line-270"></a> <span class='hs-varid'>is</span>
<a name="line-271"></a> <span class='hs-layout'>(</span><span class='hs-varid'>front</span> <span class='hs-varop'>.</span> <span class='hs-layout'>(</span><span class='hs-varid'>c</span> <span class='hs-varop'>++</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-272"></a> <span class='hs-conid'>Finished</span> <span class='hs-sel'>_leftover</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-273"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitClose</span> <span class='hs-varid'>outer</span>
<a name="line-274"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Finished</span> <span class='hs-conid'>Nothing</span> <span class='hs-varop'>$</span> <span class='hs-varid'>front</span> <span class='hs-varid'>c</span>
<a name="line-275"></a> <span class='hs-varid'>loop</span> <span class='hs-varid'>inner0</span> <span class='hs-varid'>inputI</span> <span class='hs-varid'>id</span>
<a name="line-276"></a> <span class='hs-conid'>Finished</span> <span class='hs-varid'>leftoverO</span> <span class='hs-varid'>inputI</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-277"></a> <span class='hs-varid'>c</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPushClose</span> <span class='hs-varid'>inner0</span> <span class='hs-varid'>inputI</span>
<a name="line-278"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Finished</span> <span class='hs-varid'>leftoverO</span> <span class='hs-varid'>c</span>
<a name="line-279"></a> <span class='hs-varid'>closeF</span> <span class='hs-varid'>outer</span> <span class='hs-varid'>inner</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-280"></a> <span class='hs-varid'>b</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitClose</span> <span class='hs-varid'>outer</span>
<a name="line-281"></a> <span class='hs-varid'>c</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPushClose</span> <span class='hs-varid'>inner</span> <span class='hs-varid'>b</span>
<a name="line-282"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>c</span>
<a name="line-283"></a>
<a name="line-284"></a><a name="conduitPushClose"></a><span class='hs-comment'>-- | Push some data to a conduit, then close it if necessary.</span>
<a name="line-285"></a><span class='hs-definition'>conduitPushClose</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Monad</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>a</span><span class='hs-keyglyph'>]</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>b</span><span class='hs-keyglyph'>]</span>
<a name="line-286"></a><span class='hs-definition'>conduitPushClose</span> <span class='hs-varid'>c</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>conduitClose</span> <span class='hs-varid'>c</span>
<a name="line-287"></a><span class='hs-definition'>conduitPushClose</span> <span class='hs-varid'>c</span> <span class='hs-layout'>(</span><span class='hs-varid'>input</span><span class='hs-conop'>:</span><span class='hs-varid'>rest</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-288"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPush</span> <span class='hs-varid'>c</span> <span class='hs-varid'>input</span>
<a name="line-289"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-290"></a> <span class='hs-conid'>Finished</span> <span class='hs-keyword'>_</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>b</span>
<a name="line-291"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-292"></a> <span class='hs-varid'>b'</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPushClose</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>rest</span>
<a name="line-293"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-varid'>b</span> <span class='hs-varop'>++</span> <span class='hs-varid'>b'</span>
<a name="line-294"></a>
<a name="line-295"></a><a name="BufferedSource"></a><span class='hs-comment'>-- | When actually interacting with @Source@s, we sometimes want to be able to</span>
<a name="line-296"></a><a name="BufferedSource"></a><span class='hs-comment'>-- buffer the output, in case any intermediate steps return leftover data. A</span>
<a name="line-297"></a><a name="BufferedSource"></a><span class='hs-comment'>-- @BufferedSource@ allows for such buffering.</span>
<a name="line-298"></a><a name="BufferedSource"></a><span class='hs-comment'>--</span>
<a name="line-299"></a><a name="BufferedSource"></a><span class='hs-comment'>-- A @BufferedSource@, unlike a @Source@, is resumable, meaning it can be</span>
<a name="line-300"></a><a name="BufferedSource"></a><span class='hs-comment'>-- passed to multiple @Sink@s without restarting. Therefore, a @BufferedSource@</span>
<a name="line-301"></a><a name="BufferedSource"></a><span class='hs-comment'>-- relaxes the main invariant of this package: the same value may be used</span>
<a name="line-302"></a><a name="BufferedSource"></a><span class='hs-comment'>-- multiple times.</span>
<a name="line-303"></a><a name="BufferedSource"></a><span class='hs-comment'>--</span>
<a name="line-304"></a><a name="BufferedSource"></a><span class='hs-comment'>-- The intention of a @BufferedSource@ is to be used internally by an</span>
<a name="line-305"></a><a name="BufferedSource"></a><span class='hs-comment'>-- application or library, not to be part of its user-facing API. For example,</span>
<a name="line-306"></a><a name="BufferedSource"></a><span class='hs-comment'>-- the Warp webserver uses a @BufferedSource@ internally for parsing the</span>
<a name="line-307"></a><a name="BufferedSource"></a><span class='hs-comment'>-- request headers, but then passes a normal @Source@ to the web application</span>
<a name="line-308"></a><a name="BufferedSource"></a><span class='hs-comment'>-- for reading the request body.</span>
<a name="line-309"></a><a name="BufferedSource"></a><span class='hs-comment'>--</span>
<a name="line-310"></a><a name="BufferedSource"></a><span class='hs-comment'>-- One caveat: while the types will allow you to use the buffered source in</span>
<a name="line-311"></a><a name="BufferedSource"></a><span class='hs-comment'>-- multiple threads, there is no guarantee that all @BufferedSource@s will</span>
<a name="line-312"></a><a name="BufferedSource"></a><span class='hs-comment'>-- handle this correctly.</span>
<a name="line-313"></a><a name="BufferedSource"></a><span class='hs-comment'>--</span>
<a name="line-314"></a><a name="BufferedSource"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-315"></a><a name="BufferedSource"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>BufferedSource</span> <span class='hs-layout'>(</span><span class='hs-conid'>Ref</span> <span class='hs-layout'>(</span><span class='hs-conid'>Base</span> <span class='hs-varid'>m</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-conid'>BSState</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-316"></a>
<a name="line-317"></a><a name="BSState"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>BSState</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=</span>
<a name="line-318"></a> <span class='hs-conid'>ClosedEmpty</span>
<a name="line-319"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>OpenEmpty</span> <span class='hs-layout'>(</span><span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-320"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>ClosedFull</span> <span class='hs-varid'>a</span>
<a name="line-321"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>OpenFull</span> <span class='hs-layout'>(</span><span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span> <span class='hs-varid'>a</span>
<a name="line-322"></a>
<a name="line-323"></a><a name="bufferSource"></a><span class='hs-comment'>-- | Places the given @Source@ and a buffer into a mutable variable. Note that</span>
<a name="line-324"></a><span class='hs-comment'>-- you should manually call 'bsourceClose' when the 'BufferedSource' is no</span>
<a name="line-325"></a><span class='hs-comment'>-- longer in use.</span>
<a name="line-326"></a><span class='hs-comment'>--</span>
<a name="line-327"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-328"></a><span class='hs-definition'>bufferSource</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-layout'>(</span><span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-329"></a><span class='hs-definition'>bufferSource</span> <span class='hs-varid'>src</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varop'><$></span> <span class='hs-varid'>newRef</span> <span class='hs-layout'>(</span><span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span><span class='hs-layout'>)</span>
<a name="line-330"></a>
<a name="line-331"></a><a name="unbufferSource"></a><span class='hs-comment'>-- | Turn a 'BufferedSource' into a 'Source'. Note that in general this will</span>
<a name="line-332"></a><span class='hs-comment'>-- mean your original 'BufferedSource' will be closed. Additionally, all</span>
<a name="line-333"></a><span class='hs-comment'>-- leftover data from usage of the returned @Source@ will be discarded. In</span>
<a name="line-334"></a><span class='hs-comment'>-- other words: this is a no-going-back move.</span>
<a name="line-335"></a><span class='hs-comment'>--</span>
<a name="line-336"></a><span class='hs-comment'>-- Note: @bufferSource@ . @unbufferSource@ is /not/ the identity function.</span>
<a name="line-337"></a><span class='hs-comment'>--</span>
<a name="line-338"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-339"></a><span class='hs-definition'>unbufferSource</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span>
<a name="line-340"></a> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span>
<a name="line-341"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span>
<a name="line-342"></a><span class='hs-definition'>unbufferSource</span> <span class='hs-layout'>(</span><span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>bs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Source</span>
<a name="line-343"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>sourcePull</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>msrc</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>sourcePull</span>
<a name="line-344"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sourceClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>msrc</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>sourceClose</span>
<a name="line-345"></a> <span class='hs-layout'>}</span>
<a name="line-346"></a> <span class='hs-keyword'>where</span>
<a name="line-347"></a> <span class='hs-varid'>msrc</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-348"></a> <span class='hs-varid'>buf</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readRef</span> <span class='hs-varid'>bs</span>
<a name="line-349"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>buf</span> <span class='hs-keyword'>of</span>
<a name="line-350"></a> <span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>src</span>
<a name="line-351"></a> <span class='hs-conid'>OpenFull</span> <span class='hs-varid'>src</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Source</span>
<a name="line-352"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>sourcePull</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span> <span class='hs-varid'>src</span> <span class='hs-varid'>a</span>
<a name="line-353"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sourceClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sourceClose</span> <span class='hs-varid'>src</span>
<a name="line-354"></a> <span class='hs-layout'>}</span>
<a name="line-355"></a> <span class='hs-conid'>ClosedEmpty</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Source</span>
<a name="line-356"></a> <span class='hs-comment'>-- Note: we could put some invariant checking in here if we wanted</span>
<a name="line-357"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>sourcePull</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span>
<a name="line-358"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sourceClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-359"></a> <span class='hs-layout'>}</span>
<a name="line-360"></a> <span class='hs-conid'>ClosedFull</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Source</span>
<a name="line-361"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>sourcePull</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-362"></a> <span class='hs-layout'>(</span><span class='hs-conid'>Source</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-363"></a> <span class='hs-varid'>a</span>
<a name="line-364"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sourceClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-365"></a> <span class='hs-layout'>}</span>
<a name="line-366"></a>
<a name="line-367"></a><a name="bufferedConnect"></a><span class='hs-definition'>bufferedConnect</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Sink</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-368"></a><span class='hs-definition'>bufferedConnect</span> <span class='hs-keyword'>_</span> <span class='hs-layout'>(</span><span class='hs-conid'>SinkNoData</span> <span class='hs-varid'>output</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-varid'>output</span>
<a name="line-369"></a><span class='hs-definition'>bufferedConnect</span> <span class='hs-varid'>bsrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>SinkLift</span> <span class='hs-varid'>msink</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>msink</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>bufferedConnect</span> <span class='hs-varid'>bsrc</span>
<a name="line-370"></a><span class='hs-definition'>bufferedConnect</span> <span class='hs-layout'>(</span><span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>bs</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-conid'>SinkData</span> <span class='hs-varid'>push0</span> <span class='hs-varid'>close0</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-371"></a> <span class='hs-varid'>bsState</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readRef</span> <span class='hs-varid'>bs</span>
<a name="line-372"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>bsState</span> <span class='hs-keyword'>of</span>
<a name="line-373"></a> <span class='hs-conid'>ClosedEmpty</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>close0</span>
<a name="line-374"></a> <span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>connect'</span> <span class='hs-varid'>src</span> <span class='hs-varid'>push0</span> <span class='hs-varid'>close0</span>
<a name="line-375"></a> <span class='hs-conid'>ClosedFull</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-376"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>push0</span> <span class='hs-varid'>a</span>
<a name="line-377"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-378"></a> <span class='hs-conid'>Done</span> <span class='hs-varid'>mleftover</span> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-379"></a> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-varop'>$</span> <span class='hs-varid'>maybe</span> <span class='hs-conid'>ClosedEmpty</span> <span class='hs-conid'>ClosedFull</span> <span class='hs-varid'>mleftover</span>
<a name="line-380"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>res'</span>
<a name="line-381"></a> <span class='hs-conid'>Processing</span> <span class='hs-keyword'>_</span> <span class='hs-varid'>close'</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-382"></a> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-conid'>ClosedEmpty</span>
<a name="line-383"></a> <span class='hs-varid'>close'</span>
<a name="line-384"></a> <span class='hs-conid'>OpenFull</span> <span class='hs-varid'>src</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>push0</span> <span class='hs-varid'>a</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>onRes</span> <span class='hs-varid'>src</span>
<a name="line-385"></a> <span class='hs-keyword'>where</span>
<a name="line-386"></a> <span class='hs-varid'>connect'</span> <span class='hs-varid'>src</span> <span class='hs-varid'>push</span> <span class='hs-varid'>close</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-387"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>sourcePull</span> <span class='hs-varid'>src</span>
<a name="line-388"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-389"></a> <span class='hs-conid'>Closed</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-390"></a> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-conid'>ClosedEmpty</span>
<a name="line-391"></a> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>close</span>
<a name="line-392"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>res'</span>
<a name="line-393"></a> <span class='hs-conid'>Open</span> <span class='hs-varid'>src'</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>push</span> <span class='hs-varid'>a</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>onRes</span> <span class='hs-varid'>src'</span>
<a name="line-394"></a> <span class='hs-varid'>onRes</span> <span class='hs-varid'>src</span> <span class='hs-layout'>(</span><span class='hs-conid'>Done</span> <span class='hs-varid'>mleftover</span> <span class='hs-varid'>res</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-395"></a> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-varop'>$</span> <span class='hs-varid'>maybe</span> <span class='hs-layout'>(</span><span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-conid'>OpenFull</span> <span class='hs-varid'>src</span><span class='hs-layout'>)</span> <span class='hs-varid'>mleftover</span>
<a name="line-396"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>res</span>
<a name="line-397"></a> <span class='hs-varid'>onRes</span> <span class='hs-varid'>src</span> <span class='hs-layout'>(</span><span class='hs-conid'>Processing</span> <span class='hs-varid'>push</span> <span class='hs-varid'>close</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>connect'</span> <span class='hs-varid'>src</span> <span class='hs-varid'>push</span> <span class='hs-varid'>close</span>
<a name="line-398"></a>
<a name="line-399"></a><a name="bufferedFuseLeft"></a><span class='hs-definition'>bufferedFuseLeft</span>
<a name="line-400"></a> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span>
<a name="line-401"></a> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span>
<a name="line-402"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Conduit</span> <span class='hs-varid'>a</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-403"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Source</span> <span class='hs-varid'>m</span> <span class='hs-varid'>b</span>
<a name="line-404"></a><span class='hs-definition'>bufferedFuseLeft</span> <span class='hs-varid'>bsrc</span> <span class='hs-varid'>conduit0</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Source</span>
<a name="line-405"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>sourcePull</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>pullF</span> <span class='hs-varop'>$</span> <span class='hs-conid'>FLOpen</span> <span class='hs-conid'>()</span> <span class='hs-varid'>conduit0</span> <span class='hs-conid'>[]</span> <span class='hs-comment'>-- still open, no buffer</span>
<a name="line-406"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sourceClose</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-407"></a> <span class='hs-layout'>}</span>
<a name="line-408"></a> <span class='hs-keyword'>where</span>
<a name="line-409"></a> <span class='hs-varid'>mkSrc</span> <span class='hs-varid'>state</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Source</span>
<a name="line-410"></a> <span class='hs-layout'>(</span><span class='hs-varid'>pullF</span> <span class='hs-varid'>state</span><span class='hs-layout'>)</span>
<a name="line-411"></a> <span class='hs-layout'>(</span><span class='hs-varid'>closeF</span> <span class='hs-varid'>state</span><span class='hs-layout'>)</span>
<a name="line-412"></a> <span class='hs-varid'>pullF</span> <span class='hs-varid'>state'</span> <span class='hs-keyglyph'>=</span>
<a name="line-413"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>state'</span> <span class='hs-keyword'>of</span>
<a name="line-414"></a> <span class='hs-conid'>FLClosed</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span>
<a name="line-415"></a> <span class='hs-conid'>FLClosed</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-416"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLClosed</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-417"></a> <span class='hs-varid'>x</span>
<a name="line-418"></a> <span class='hs-conid'>FLOpen</span> <span class='hs-conid'>()</span> <span class='hs-varid'>conduit</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-419"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLOpen</span> <span class='hs-conid'>()</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-420"></a> <span class='hs-varid'>x</span>
<a name="line-421"></a> <span class='hs-conid'>FLOpen</span> <span class='hs-conid'>()</span> <span class='hs-varid'>conduit</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-422"></a> <span class='hs-varid'>mres</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>bsourcePull</span> <span class='hs-varid'>bsrc</span>
<a name="line-423"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mres</span> <span class='hs-keyword'>of</span>
<a name="line-424"></a> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-425"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitClose</span> <span class='hs-varid'>conduit</span>
<a name="line-426"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-427"></a> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span>
<a name="line-428"></a> <span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-429"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLClosed</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-430"></a> <span class='hs-varid'>x</span>
<a name="line-431"></a> <span class='hs-conid'>Just</span> <span class='hs-varid'>input</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-432"></a> <span class='hs-varid'>res'</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>conduitPush</span> <span class='hs-varid'>conduit</span> <span class='hs-varid'>input</span>
<a name="line-433"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res'</span> <span class='hs-keyword'>of</span>
<a name="line-434"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>conduit'</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span>
<a name="line-435"></a> <span class='hs-varid'>pullF</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLOpen</span> <span class='hs-conid'>()</span> <span class='hs-varid'>conduit'</span> <span class='hs-conid'>[]</span><span class='hs-layout'>)</span>
<a name="line-436"></a> <span class='hs-conid'>Producing</span> <span class='hs-varid'>conduit'</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-437"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLOpen</span> <span class='hs-conid'>()</span> <span class='hs-varid'>conduit'</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-438"></a> <span class='hs-varid'>x</span>
<a name="line-439"></a> <span class='hs-conid'>Finished</span> <span class='hs-varid'>leftover</span> <span class='hs-varid'>output</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-440"></a> <span class='hs-varid'>bsourceUnpull</span> <span class='hs-varid'>bsrc</span> <span class='hs-varid'>leftover</span>
<a name="line-441"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>output</span> <span class='hs-keyword'>of</span>
<a name="line-442"></a> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Closed</span>
<a name="line-443"></a> <span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Open</span>
<a name="line-444"></a> <span class='hs-layout'>(</span><span class='hs-varid'>mkSrc</span> <span class='hs-layout'>(</span><span class='hs-conid'>FLClosed</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-445"></a> <span class='hs-varid'>x</span>
<a name="line-446"></a> <span class='hs-varid'>closeF</span> <span class='hs-varid'>state</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-447"></a> <span class='hs-comment'>-- Normally we don't have to worry about double closing, as the</span>
<a name="line-448"></a> <span class='hs-comment'>-- invariant of a source is that close is never called twice. However,</span>
<a name="line-449"></a> <span class='hs-comment'>-- here, if the Conduit returned Finished with some data, the overall</span>
<a name="line-450"></a> <span class='hs-comment'>-- Source will return an Open while the Conduit will be Closed.</span>
<a name="line-451"></a> <span class='hs-comment'>-- Therefore, we have to do a check.</span>
<a name="line-452"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>state</span> <span class='hs-keyword'>of</span>
<a name="line-453"></a> <span class='hs-conid'>FLClosed</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-454"></a> <span class='hs-conid'>FLOpen</span> <span class='hs-conid'>()</span> <span class='hs-layout'>(</span><span class='hs-conid'>Conduit</span> <span class='hs-keyword'>_</span> <span class='hs-varid'>close</span><span class='hs-layout'>)</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-455"></a> <span class='hs-sel'>_ignored</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>close</span>
<a name="line-456"></a> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-457"></a>
<a name="line-458"></a><a name="bsourcePull"></a><span class='hs-definition'>bsourcePull</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-layout'>(</span><span class='hs-conid'>Maybe</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-459"></a><span class='hs-definition'>bsourcePull</span> <span class='hs-layout'>(</span><span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>bs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-460"></a> <span class='hs-varid'>buf</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readRef</span> <span class='hs-varid'>bs</span>
<a name="line-461"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>buf</span> <span class='hs-keyword'>of</span>
<a name="line-462"></a> <span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-463"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>sourcePull</span> <span class='hs-varid'>src</span>
<a name="line-464"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>res</span> <span class='hs-keyword'>of</span>
<a name="line-465"></a> <span class='hs-conid'>Open</span> <span class='hs-varid'>src'</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-466"></a> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-varop'>$</span> <span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src'</span>
<a name="line-467"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Just</span> <span class='hs-varid'>a</span>
<a name="line-468"></a> <span class='hs-conid'>Closed</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-conid'>ClosedEmpty</span> <span class='hs-varop'>>></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Nothing</span>
<a name="line-469"></a> <span class='hs-conid'>ClosedEmpty</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Nothing</span>
<a name="line-470"></a> <span class='hs-conid'>OpenFull</span> <span class='hs-varid'>src</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-471"></a> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-layout'>(</span><span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span><span class='hs-layout'>)</span>
<a name="line-472"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Just</span> <span class='hs-varid'>a</span>
<a name="line-473"></a> <span class='hs-conid'>ClosedFull</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-474"></a> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>bs</span> <span class='hs-conid'>ClosedEmpty</span>
<a name="line-475"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Just</span> <span class='hs-varid'>a</span>
<a name="line-476"></a>
<a name="line-477"></a><a name="bsourceUnpull"></a><span class='hs-definition'>bsourceUnpull</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Maybe</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-conid'>()</span>
<a name="line-478"></a><span class='hs-definition'>bsourceUnpull</span> <span class='hs-keyword'>_</span> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-479"></a><span class='hs-definition'>bsourceUnpull</span> <span class='hs-layout'>(</span><span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-conid'>Just</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-480"></a> <span class='hs-varid'>buf</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readRef</span> <span class='hs-varid'>ref</span>
<a name="line-481"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>buf</span> <span class='hs-keyword'>of</span>
<a name="line-482"></a> <span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>ref</span> <span class='hs-layout'>(</span><span class='hs-conid'>OpenFull</span> <span class='hs-varid'>src</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-483"></a> <span class='hs-conid'>ClosedEmpty</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>writeRef</span> <span class='hs-varid'>ref</span> <span class='hs-layout'>(</span><span class='hs-conid'>ClosedFull</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-484"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>error</span> <span class='hs-varop'>$</span> <span class='hs-str'>"Invariant violated: bsourceUnpull called on full data"</span>
<a name="line-485"></a>
<a name="line-486"></a><a name="bsourceClose"></a><span class='hs-comment'>-- | Close the underlying 'Source' for the given 'BufferedSource'. Note</span>
<a name="line-487"></a><span class='hs-comment'>-- that this function can safely be called multiple times, as it will first</span>
<a name="line-488"></a><span class='hs-comment'>-- check if the 'Source' was previously closed.</span>
<a name="line-489"></a><span class='hs-comment'>--</span>
<a name="line-490"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-491"></a><span class='hs-definition'>bsourceClose</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Resource</span> <span class='hs-varid'>m</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>m</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ResourceT</span> <span class='hs-varid'>m</span> <span class='hs-conid'>()</span>
<a name="line-492"></a><span class='hs-definition'>bsourceClose</span> <span class='hs-layout'>(</span><span class='hs-conid'>BufferedSource</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-493"></a> <span class='hs-varid'>buf</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readRef</span> <span class='hs-varid'>ref</span>
<a name="line-494"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>buf</span> <span class='hs-keyword'>of</span>
<a name="line-495"></a> <span class='hs-conid'>OpenEmpty</span> <span class='hs-varid'>src</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>sourceClose</span> <span class='hs-varid'>src</span>
<a name="line-496"></a> <span class='hs-conid'>OpenFull</span> <span class='hs-varid'>src</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>sourceClose</span> <span class='hs-varid'>src</span>
<a name="line-497"></a> <span class='hs-conid'>ClosedEmpty</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-498"></a> <span class='hs-conid'>ClosedFull</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-499"></a><a name="Flush"></a><span class='hs-comment'>-- | Provide for a stream of data that can be flushed.</span>
<a name="line-500"></a><a name="Flush"></a><span class='hs-comment'>--</span>
<a name="line-501"></a><a name="Flush"></a><span class='hs-comment'>-- A number of @Conduit@s (e.g., zlib compression) need the ability to flush</span>
<a name="line-502"></a><a name="Flush"></a><span class='hs-comment'>-- the stream at some point. This provides a single wrapper datatype to be used</span>
<a name="line-503"></a><a name="Flush"></a><span class='hs-comment'>-- in all such circumstances.</span>
<a name="line-504"></a><a name="Flush"></a><span class='hs-comment'>--</span>
<a name="line-505"></a><a name="Flush"></a><span class='hs-comment'>-- Since 0.2.0</span>
<a name="line-506"></a><a name="Flush"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>Flush</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Chunk</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>Flush</span>
<a name="line-507"></a> <span class='hs-keyword'>deriving</span> <span class='hs-layout'>(</span><span class='hs-conid'>Show</span><span class='hs-layout'>,</span> <span class='hs-conid'>Eq</span><span class='hs-layout'>,</span> <span class='hs-conid'>Ord</span><span class='hs-layout'>)</span>
<a name="line-508"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>Functor</span> <span class='hs-conid'>Flush</span> <span class='hs-keyword'>where</span>
<a name="line-509"></a> <span class='hs-varid'>fmap</span> <span class='hs-keyword'>_</span> <span class='hs-conid'>Flush</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Flush</span>
<a name="line-510"></a> <span class='hs-varid'>fmap</span> <span class='hs-varid'>f</span> <span class='hs-layout'>(</span><span class='hs-conid'>Chunk</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Chunk</span> <span class='hs-layout'>(</span><span class='hs-varid'>f</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
</pre></body>
</html>
