* Resolve connection * @returns {Promise }
()
| 179 | * @returns {Promise<unknown>} |
| 180 | */ |
| 181 | async waitForConnection() { |
| 182 | return new Promise((resolve, reject) => { |
| 183 | if (this._closed) { |
| 184 | reject(new Error('BiDi connection is closed')) |
| 185 | return |
| 186 | } |
| 187 | if (this.connected) { |
| 188 | resolve() |
| 189 | return |
| 190 | } |
| 191 | // Park the waiter in a Set so the constructor's 'open' handler can |
| 192 | // resolve it and _failPending() can reject it. Avoids attaching socket |
| 193 | // listeners that close()'s removeAllListeners('close') would strip. |
| 194 | this._connectWaiters.add({ resolve, reject }) |
| 195 | }) |
| 196 | } |
| 197 | |
| 198 | /** |
| 199 | * Sends a bidi request |
no test coverage detected