@@ -7,6 +7,7 @@ module Network.Wai.Handler.Warp.HTTP2.Sender (frameSender) where
77#if __GLASGOW_HASKELL__ < 709
88import Control.Applicative
99#endif
10+import Control.Concurrent (forkIO)
1011import Control.Concurrent.STM
1112import qualified Control.Exception as E
1213import Control.Monad (unless, void, when)
@@ -154,13 +155,13 @@ frameSender ctx@Context{outputQ,controlQ,connectionWindow,encodeDynamicTable}
154155 checkStreaming tbq = do
155156 isEmpty <- atomically $ isEmptyTBQueue tbq
156157 if isEmpty then
157− enqueueWhenReady (waitStreaming tbq) outputQ out
158+ void . forkIO $ enqueueWhenReady (waitStreaming tbq) outputQ out
158159 else
159160 checkStreamWindowSize
160161 checkStreamWindowSize = do
161162 sws <- getStreamWindowSize strm
162163 if sws == 0 then do
163− enqueueWhenReady (waitStreamWindowSize strm) outputQ out
164+ void . forkIO $ enqueueWhenReady (waitStreamWindowSize strm) outputQ out
164165 else
165166 body sws
166167 resetStream e = do