forked from defunkt/toes
Fix SSE ping heartbeat message format
This commit is contained in:
parent
cf018004a2
commit
99492a35e8
|
|
@ -12,7 +12,7 @@ router.sse('/stream', (send) => {
|
||||||
queue = queue.then(() => send(...args))
|
queue = queue.then(() => send(...args))
|
||||||
}
|
}
|
||||||
const unsub = onEvent(event => safeSend(event))
|
const unsub = onEvent(event => safeSend(event))
|
||||||
const heartbeat = setInterval(() => safeSend('', 'ping'), 60_000)
|
const heartbeat = setInterval(() => safeSend({ type: 'ping' }, 'ping'), 60_000)
|
||||||
return () => {
|
return () => {
|
||||||
clearInterval(heartbeat)
|
clearInterval(heartbeat)
|
||||||
unsub()
|
unsub()
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user