File tree Expand file tree Collapse file tree 2 files changed +2
-29
lines changed
packages/services/api/src/modules
app-deployments/providers Expand file tree Collapse file tree 2 files changed +2
-29
lines changed Original file line number Diff line number Diff line change @@ -88,7 +88,7 @@ export class PersistedDocumentScheduler {
88
88
89
89
return async function batchProcess ( data : BatchProcessEvent [ 'data' ] ) {
90
90
const id = crypto . randomUUID ( ) ;
91
- const d = createDeferred < BatchProcessedEvent > ( ) ;
91
+ const d = Promise . withResolvers < BatchProcessedEvent > ( ) ;
92
92
const timeout = setTimeout ( ( ) => {
93
93
task . reject ( new Error ( 'Timeout, worker did not respond within time.' ) ) ;
94
94
} , 20_000 ) ;
@@ -132,18 +132,3 @@ export class PersistedDocumentScheduler {
132
132
return this . getRandomWorker ( ) ( data ) ;
133
133
}
134
134
}
135
-
136
- function createDeferred < T = void > ( ) {
137
- let resolve : ( value : T ) => void ;
138
- let reject : ( error : unknown ) => void ;
139
- const promise = new Promise < T > ( ( res , rej ) => {
140
- resolve = res ;
141
- reject = rej ;
142
- } ) ;
143
-
144
- return {
145
- resolve : ( value : T ) => resolve ( value ) ,
146
- reject : ( error : unknown ) => reject ( error ) ,
147
- promise,
148
- } ;
149
- }
Original file line number Diff line number Diff line change @@ -63,7 +63,7 @@ const scheduleTask = (args: {
63
63
args . logger . info ( `Completed running task "${ args . name } " to run at ${ runsAt } .` ) ;
64
64
deferred . resolve ( ) ;
65
65
} , args . runInMilliSeconds ) ;
66
- const deferred = createDeferred ( ) ;
66
+ const deferred = Promise . withResolvers < void > ( ) ;
67
67
68
68
return {
69
69
done : deferred . promise ,
@@ -75,15 +75,3 @@ const scheduleTask = (args: {
75
75
} ,
76
76
} ;
77
77
} ;
78
-
79
- const createDeferred = ( ) => {
80
- let resolve : ( ) => void ;
81
- const promise = new Promise < void > ( r => {
82
- resolve = r ;
83
- } ) ;
84
-
85
- return {
86
- resolve : ( ) => resolve ( ) ,
87
- promise,
88
- } ;
89
- } ;
You can’t perform that action at this time.
0 commit comments