@@ -97,7 +97,7 @@ dequeue :: forall m a.
9797 -> IO (Maybe a) -- ^ 'Nothing' only on timeout
9898dequeue (CQueue arrived incoming) blockSpec matchons =
9999 case blockSpec of
100− Timeout n -> timeout n $ fmap fromJust go
100+ Timeout n -> timeout n $ fmap fromJust run
101101 _other ->
102102 case chunks of
103103 [Right ports] -> -- channels only, this is easy:
@@ -105,11 +105,11 @@ dequeue (CQueue arrived incoming) blockSpec matchons =
105105 NonBlocking -> atomically $ waitChans ports (return Nothing)
106106 _ -> atomically $ waitChans ports retry
107107 -- no onException needed
108− _other -> go
108+ _other -> run
109109 where
110110 chunks = chunkMatches matchons
111111
112− go = mask_ $ do
112+ run = mask_ $ do
113113 arr <- takeMVar arrived
114114 let grabNew xs = do
115115 r <- atomically $ tryReadTChan incoming