* @param {EventSourceStreamEvent} event
(event)
| 319 | * @param {EventSourceStreamEvent} event |
| 320 | */ |
| 321 | processEvent (event) { |
| 322 | if (event.retry && isASCIINumber(event.retry)) { |
| 323 | this.state.reconnectionTime = parseInt(event.retry, 10) |
| 324 | } |
| 325 | |
| 326 | if (event.id !== undefined && isValidLastEventId(event.id)) { |
| 327 | this.state.lastEventId = event.id |
| 328 | } |
| 329 | |
| 330 | // only dispatch event, when data is provided |
| 331 | if (event.data !== undefined) { |
| 332 | this.push({ |
| 333 | type: event.event || 'message', |
| 334 | options: { |
| 335 | data: event.data, |
| 336 | lastEventId: this.state.lastEventId, |
| 337 | origin: this.state.origin |
| 338 | } |
| 339 | }) |
| 340 | } |
| 341 | } |
| 342 | |
| 343 | clearEvent () { |
| 344 | this.event.data = undefined |
no test coverage detected