* Resolve connection * @returns {Promise }
()
| 227 | * @returns {Promise<unknown>} |
| 228 | */ |
| 229 | async waitForConnection() { |
| 230 | return new Promise((resolve, reject) => { |
| 231 | if (this._closed) { |
| 232 | reject(new Error('BiDi connection is closed')) |
| 233 | return |
| 234 | } |
| 235 | if (this.connected) { |
| 236 | resolve() |
| 237 | return |
| 238 | } |
| 239 | // Park the waiter in a Set so the constructor's 'open' handler can |
| 240 | // resolve it and _failPending() can reject it. Avoids attaching socket |
| 241 | // listeners that close()'s removeAllListeners('close') would strip. |
| 242 | this._connectWaiters.add({ resolve, reject }) |
| 243 | }) |
| 244 | } |
| 245 | |
| 246 | /** |
| 247 | * Sends a bidi request |
no test coverage detected