From 9bd50a3795c7bd4bca84c07a5648a4901cc8f511 Mon Sep 17 00:00:00 2001
From: a <a@tuxpa.in>
Date: Tue, 26 Dec 2023 01:48:38 -0600
Subject: [PATCH] sse
---
contrib/codecs/http/codecs.go | 2 +-
example/subscription/main.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/contrib/codecs/http/codecs.go b/contrib/codecs/http/codecs.go
index a930170..121e740 100644
--- a/contrib/codecs/http/codecs.go
+++ b/contrib/codecs/http/codecs.go
@@ -31,7 +31,7 @@ type HttpCodec struct {
func NewCodec(w http.ResponseWriter, r *http.Request) (jsonrpc.ReaderWriter, error) {
switch r.Method {
case http.MethodGet:
- if r.Header.Get("Accept") == "text/event-stream" {
+ if r.Header.Get("Accept") == "text/event-stream" || r.URL.Query().Has("sse") {
return NewSseCodec(w, r)
}
return NewGetCodec(w, r), nil
diff --git a/example/subscription/main.go b/example/subscription/main.go
index 38014a6..bf87299 100644
--- a/example/subscription/main.go
+++ b/example/subscription/main.go
@@ -77,6 +77,6 @@ func client() error {
}()
defer jcs.Unsubscribe()
for {
- log.Println("receiving", <-out)
+ //log.Println("receiving", <-out)
}
}
--
GitLab