@@ -14,45 +14,19 @@ export const deadlockReleasingQueue = queue({
1414export  const  deadlockTester  =  task ( { 
1515  id : "deadlock-tester" , 
1616  run : async  ( payload : any ,  {  ctx } )  =>  { 
17-     // await deadlockNestedTask.triggerAndWait({ 
18-     //   message: "Hello, world!", 
19-     // }); 
20- 
21-     await  deadlockNestedTask . batchTriggerAndWait ( [ 
22-       { 
23-         payload : { 
24-           message : "Hello, world!" , 
25-         } , 
26-       } , 
27-       { 
28-         payload : { 
29-           message : "Hello, world!" , 
30-         } , 
31-       } , 
32-     ] ) ; 
17+     await  deadlockNestedTask . triggerAndWait ( { 
18+       message : "Hello, world!" , 
19+     } ) ; 
3320  } , 
3421} ) ; 
3522
3623export  const  deadlockNestedTask  =  task ( { 
3724  id : "deadlock-nested-task" , 
3825  queue : deadlockQueue , 
3926  run : async  ( payload : any ,  {  ctx } )  =>  { 
40-     // await deadlockTester.triggerAndWait({ 
41-     //   message: "Hello, world!", 
42-     // }); 
43- 
44-     await  deadlockTester . batchTriggerAndWait ( [ 
45-       { 
46-         payload : { 
47-           message : "Hello, world!" , 
48-         } , 
49-       } , 
50-       { 
51-         payload : { 
52-           message : "Hello, world!" , 
53-         } , 
54-       } , 
55-     ] ) ; 
27+     await  deadlockTester . triggerAndWait ( { 
28+       message : "Hello, world!" , 
29+     } ) ; 
5630
5731    return  { 
5832      message : "Hello, world!" , 
0 commit comments