(socket, eventType)
| 39 | } |
| 40 | |
| 41 | function waitFor(socket, eventType) { |
| 42 | if (socket._eventBuffer[eventType].length) { |
| 43 | return Promise.resolve(socket._eventBuffer[eventType].shift()); |
| 44 | } else { |
| 45 | return new Promise((resolve) => { |
| 46 | socket._pendingPromises[eventType].push(resolve); |
| 47 | }); |
| 48 | } |
| 49 | } |
| 50 | |
| 51 | async function initLongPollingSession() { |
| 52 | const response = await fetch(`${URL}/engine.io/?EIO=4&transport=polling`); |