()
| 455 | } |
| 456 | |
| 457 | function processMessageQueue(): void { |
| 458 | if (messageQueue.size === 0) { |
| 459 | return; |
| 460 | } |
| 461 | let message = messageQueue.shift()!; |
| 462 | try { |
| 463 | if (isRequestMessage(message)) { |
| 464 | handleRequest(message); |
| 465 | } else if (isNotificationMessage(message)) { |
| 466 | handleNotification(message); |
| 467 | } else if (isResponseMessage(message)) { |
| 468 | handleResponse(message); |
| 469 | } else { |
| 470 | handleInvalidMessage(message); |
| 471 | } |
| 472 | } finally { |
| 473 | triggerMessageQueue(); |
| 474 | } |
| 475 | } |
| 476 | |
| 477 | let callback: DataCallback = (message) => { |
| 478 | try { |
no test coverage detected