(message: string)
| 171 | } |
| 172 | |
| 173 | function resetIdleTimeout(message: string) { |
| 174 | if (completed) return |
| 175 | if (!options.idleTimeout) return |
| 176 | if (idleTimer) clearTimeout(idleTimer) |
| 177 | idleTimer = setTimeout(() => invalidate(new ProviderError.ResponseStreamError(message)), options.idleTimeout) |
| 178 | } |
| 179 | |
| 180 | async function onMessage(data: WebSocket.RawData, isBinary: boolean) { |
| 181 | if (completed) return |
no test coverage detected