GlcoinCore/lightningtipbot
1
0
Fork 0
mirror of https://github.com/ChuckNorrison/LightningTipBot.git synced 2026-08-18 13:08:52 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

sse

Browse source
This commit is contained in:
gohumble 2022-08-21 00:02:48 +02:00
parent a0f7cf09e6
commit 3a4f99314d
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
internal/api/lightning.go
View file

@ -140,7 +140,9 @@ func (s Service) InvoiceStream(w http.ResponseWriter, r *http.Request) {
return
}
w.Header().Set("Content-Type", "text/event-stream")
flusher.Flush()
w.Header().Set("Cache-Control", "no-cache")
w.Header().Set("Connection", "keep-alive")
client.Subscribe("", func(msg *sse.Event) {
// Got some data!
@ -156,7 +158,7 @@ func (s Service) InvoiceStream(w http.ResponseWriter, r *http.Request) {
}
}
if msg.Data != nil {
fmt.Fprintf(w, "%s", string(msg.Data))
fmt.Fprintf(w, "data: %s\n", msg.Event)
}
flusher.Flush()
})