| 179 | } |
| 180 | |
| 181 | async function mainSerial() { |
| 182 | console.log("Preparing serial perf tests..."); |
| 183 | |
| 184 | // wait for 10 seconds |
| 185 | await new Promise((resolve) => setTimeout(resolve, 10000)); |
| 186 | |
| 187 | console.log("Starting serial perf tests in 1 second..."); |
| 188 | |
| 189 | // wait for 1 seconds |
| 190 | await new Promise((resolve) => setTimeout(resolve, 1000)); |
| 191 | |
| 192 | // Send 25 events |
| 193 | for (let i = 0; i < 25; i++) { |
| 194 | await sendEvent(); |
| 195 | await new Promise((resolve) => setTimeout(resolve, 100)); |
| 196 | } |
| 197 | } |
| 198 | |
| 199 | async function mainConcurrency() { |
| 200 | const batches = 1; |