@@ -212,7 +212,6 @@ pushFork c m1 m2 = AsyncT $ \ctx stp yld -> do
212212{-# NOINLINE pull #-}
213213pull :: (MonadIO m, MonadThrow m) => Context a -> AsyncT m a
214214pull ctx = AsyncT $ \_ stp yld -> do
215− -- XXX push the try out of the pull loop
216215 res <- liftIO $ try (atomically $ readTChan (childChannel ctx))
217216 case res of
218217 Left e ->
@@ -232,7 +231,6 @@ pull ctx = AsyncT $ \_ stp yld -> do
232231{-# INLINE pullFork #-}
233232pullFork :: MonadAsync m => AsyncT m a -> AsyncT m a -> AsyncT m a
234233pullFork m1 m2 = AsyncT $ \_ stp yld -> do
235− -- XXX assert ctx is Nothing
236234 c <- liftIO $ newContext
237235 _ <- doFork (pushBoth c m1 m2) (handlePushException (childChannel c))
238236 (runAsyncT (pull c)) (Just c) stp yld