* Watchdog client requests for timeouts * @this {!Client} * @param {!number} utc UTC timestamp in milliseconds
(utc)
| 7087 | * @param {!number} utc UTC timestamp in milliseconds |
| 7088 | */ |
| 7089 | watchdogRequests (utc) { |
| 7090 | for (let [, value] of this._requests_by_timestamp) { |
| 7091 | let item = this._requests_by_id.get(value) |
| 7092 | let id = value |
| 7093 | let timestamp = item[0] |
| 7094 | let timespan = item[1] |
| 7095 | if ((timestamp + timespan) <= utc) { |
| 7096 | let promise = item[2] |
| 7097 | promise.reject(new Error('Timeout!')) |
| 7098 | this._requests_by_id.delete(id) |
| 7099 | this._requests_by_timestamp.delete(timestamp) |
| 7100 | } |
| 7101 | } |
| 7102 | } |
| 7103 | } |
| 7104 | |
| 7105 | exports.Client = Client |