@@ -97,7 +97,7 @@ dequeue :: forall m a.
97 -> IO (Maybe a) -- ^ 'Nothing' only on timeout
97 -> IO (Maybe a) -- ^ 'Nothing' only on timeout
98dequeue (CQueue arrived incoming) blockSpec matchons =
98dequeue (CQueue arrived incoming) blockSpec matchons =
99 case blockSpec of
99 case blockSpec of
100− Timeout n -> timeout n $ fmap fromJust go
100+ Timeout n -> timeout n $ fmap fromJust run
101 _other ->
101 _other ->
102 case chunks of
102 case chunks of
103 [Right ports] -> -- channels only, this is easy:
103 [Right ports] -> -- channels only, this is easy:
@@ -105,11 +105,11 @@ dequeue (CQueue arrived incoming) blockSpec matchons =
105 NonBlocking -> atomically $ waitChans ports (return Nothing)
105 NonBlocking -> atomically $ waitChans ports (return Nothing)
106 _ -> atomically $ waitChans ports retry
106 _ -> atomically $ waitChans ports retry
107 -- no onException needed
107 -- no onException needed
108− _other -> go
108+ _other -> run
110 chunks = chunkMatches matchons
110 chunks = chunkMatches matchons
112− go = mask_ $ do
112+ run = mask_ $ do
113 arr <- takeMVar arrived
113 arr <- takeMVar arrived
114 let grabNew xs = do
114 let grabNew xs = do
115 r <- atomically $ tryReadTChan incoming
115 r <- atomically $ tryReadTChan incoming