@@ -142,8 +142,8 @@ worker ctx@Context{inputQ,outputQ} set app responder tm = do
142142 setThreadContinue tcont True
143143 ex <- E.try $ do
144144 T.pause th
145− Input strm req <- atomically $ readTQueue inputQ
146− setStreamInfo sinfo strm req
145+ inp@(Input strm req) <- atomically $ readTQueue inputQ
146+ setStreamInfo sinfo inp
147147 T.resume th
148148 T.tickle th
149149 app req $ responder tcont th strm req
@@ -162,10 +162,10 @@ worker ctx@Context{inputQ,outputQ} set app responder tm = do
162162 clearStreamInfo sinfo
163163 when (cont1 && cont2) $ go sinfo tcont th
164164 cleanup sinfo me = do
165− m <- getStreamInfo sinfo
166− case m of
167− Nothing -> return ()
168− Just (strm,req) -> do
165+ minp <- getStreamInfo sinfo
166+ case minp of
167+ Nothing -> return ()
168+ Just (Input strm req) -> do
169169 closed ctx strm Killed
170170 let frame = resetFrame InternalError (streamNumber strm)
171171 enqueueControl outputQ 0 (OFrame frame)
@@ -218,7 +218,7 @@ getThreadContinue (ThreadContinue ref) = readIORef ref
218218----------------------------------------------------------------
219219
220220-- | The type to store enough information for 'settingsOnException'.
221−newtype StreamInfo = StreamInfo (IORef (Maybe (Stream,Request)))
221+newtype StreamInfo = StreamInfo (IORef (Maybe Input))
222222
223223newStreamInfo :: IO StreamInfo
224224newStreamInfo = StreamInfo <$> newIORef Nothing
@@ -226,8 +226,8 @@ newStreamInfo = StreamInfo <$> newIORef Nothing
226226clearStreamInfo :: StreamInfo -> IO ()
227227clearStreamInfo (StreamInfo ref) = writeIORef ref Nothing
228228
229−setStreamInfo :: StreamInfo -> Stream -> Request -> IO ()
230−setStreamInfo (StreamInfo ref) strm req = writeIORef ref $ Just (strm,req)
229+setStreamInfo :: StreamInfo -> Input -> IO ()
230+setStreamInfo (StreamInfo ref) inp = writeIORef ref $ Just inp
231231
232−getStreamInfo :: StreamInfo -> IO (Maybe (Stream, Request))
232+getStreamInfo :: StreamInfo -> IO (Maybe Input)
233233getStreamInfo (StreamInfo ref) = readIORef ref