From d759ff7079923150bd18a85b7e40e4aeac53dad2 Mon Sep 17 00:00:00 2001
From: a <a@tuxpa.in>
Date: Thu, 28 Mar 2024 13:56:55 -0500
Subject: [PATCH] a
---
pkg/jsonrpc/message.go | 2 ++
pkg/server/server.go | 2 +-
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/pkg/jsonrpc/message.go b/pkg/jsonrpc/message.go
index 6fb1559..333b64a 100644
--- a/pkg/jsonrpc/message.go
+++ b/pkg/jsonrpc/message.go
@@ -3,6 +3,7 @@ package jsonrpc
import (
"encoding/json"
"io"
+ "log"
"golang.org/x/net/context"
"golang.org/x/sync/semaphore"
@@ -17,6 +18,7 @@ type flusher interface {
func flushIfFlusher(w io.Writer) error {
if val, ok := w.(flusher); ok {
+ log.Println("flushing response from notification")
return val.Flush()
}
return nil
diff --git a/pkg/server/server.go b/pkg/server/server.go
index 1d201bf..6bafda7 100644
--- a/pkg/server/server.go
+++ b/pkg/server/server.go
@@ -128,7 +128,7 @@ func serveSingle(ctx context.Context,
}
}
handler.ServeRPC(rw, req)
- if rw.sendCalled == false && rw.id != nil {
+ if rw.sendCalled == false {
rw.Send(jsonrpc.Null, nil)
}
return nil
--
GitLab