MCPcopy Create free account
hub / github.com/nodejs/undici / processEvent

Method processEvent

lib/web/eventsource/eventsource-stream.js:321–341  ·  view source on GitHub ↗

* @param {EventSourceStreamEvent} event

(event)

Source from the content-addressed store, hash-verified

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

Callers 2

_transformMethod · 0.95

Calls 3

isASCIINumberFunction · 0.85
isValidLastEventIdFunction · 0.85
pushMethod · 0.45

Tested by

no test coverage detected