File tree Expand file tree Collapse file tree 2 files changed +13
-3
lines changed Expand file tree Collapse file tree 2 files changed +13
-3
lines changed Original file line number Diff line number Diff line change @@ -67,11 +67,11 @@ public function testInvokeWait(): void
67
67
68
68
$ results = [];
69
69
$ expected = [];
70
- for ($ i = 0 ; $ i < 10 ; ++$ i ) {
70
+ for ($ i = 0 ; $ i < 27 ; ++$ i ) {
71
71
$ expected [] = '"hello ' . $ i . '" ' ;
72
72
$ results [] = $ client ->Invoke (new InvocationRequest ([
73
73
'FunctionName ' => 'Index ' ,
74
- 'Payload ' => \json_encode (['name ' => $ i ]),
74
+ 'Payload ' => \json_encode (['name ' => $ i, ' delay ' => 80 * ( $ i % 3 ) ]),
75
75
]));
76
76
}
77
77
Original file line number Diff line number Diff line change 1
1
exports . handler = async ( event ) => {
2
- return `hello ${ event . name } ` ;
2
+ function wait ( event ) {
3
+ return new Promise ( ( resolve , reject ) => {
4
+ setTimeout ( ( ) => resolve ( `hello ${ event . name } ` ) , event . delay )
5
+ } ) ;
6
+ }
7
+
8
+ if ( typeof ( event . delay ) === "undefined" || event . delay < 1 ) {
9
+ event . delay = 1 ;
10
+ }
11
+
12
+ return wait ( event ) ;
3
13
} ;
You can’t perform that action at this time.
0 commit comments