@@ -351,26 +351,23 @@ newLabelledTBQueueIO = (atomically .) . newLabelledTBQueue
351
351
352
352
-- * Helpers for labeling Threads
353
353
354
- labelMyThread :: MonadThread m => String -> m ()
355
- labelMyThread = labelThisThread
356
-
357
354
raceLabelled :: (MonadThread m , MonadAsync m ) => (String , m a ) -> (String , m b ) -> m (Either a b )
358
355
raceLabelled (lblA, mA) (lblB, mB) =
359
356
race
360
- (labelMyThread lblA >> mA)
361
- (labelMyThread lblB >> mB)
357
+ (labelThisThread lblA >> mA)
358
+ (labelThisThread lblB >> mB)
362
359
363
360
raceLabelled_ :: (MonadThread m , MonadAsync m ) => (String , m a ) -> (String , m b ) -> m ()
364
361
raceLabelled_ = (void . ) . raceLabelled
365
362
366
363
withAsyncLabelled :: MonadAsync m => (String , m a ) -> (Async m a -> m b ) -> m b
367
- withAsyncLabelled (lbl, ma) = withAsync (labelMyThread lbl >> ma)
364
+ withAsyncLabelled (lbl, ma) = withAsync (labelThisThread lbl >> ma)
368
365
369
366
concurrentlyLabelled :: (MonadThread m , MonadAsync m ) => (String , m a ) -> (String , m b ) -> m (a , b )
370
367
concurrentlyLabelled (lblA, mA) (lblB, mB) =
371
368
concurrently
372
- (labelMyThread lblA >> mA)
373
- (labelMyThread lblB >> mB)
369
+ (labelThisThread lblA >> mA)
370
+ (labelThisThread lblB >> mB)
374
371
375
372
concurrentlyLabelled_ :: (MonadThread m , MonadAsync m ) => (String , m a ) -> (String , m b ) -> m ()
376
373
concurrentlyLabelled_ = (void . ) . concurrentlyLabelled
0 commit comments