From 9e13bfe7a4d6cbd100a0f9e121a0ece101e22ba8 Mon Sep 17 00:00:00 2001
From: a <a@tuxpa.in>
Date: Mon, 4 Dec 2023 12:03:25 -0600
Subject: [PATCH] streamer
---
pkg/server/server.go | 13 ++++---------
1 file changed, 4 insertions(+), 9 deletions(-)
diff --git a/pkg/server/server.go b/pkg/server/server.go
index aa3fdee..8897691 100644
--- a/pkg/server/server.go
+++ b/pkg/server/server.go
@@ -4,7 +4,6 @@ import (
"context"
"encoding/json"
"errors"
- "io"
"sync"
"golang.org/x/sync/semaphore"
@@ -321,20 +320,16 @@ func (c *callResponder) send(ctx context.Context, env *callEnv) (err error) {
switch cast := (env.v).(type) {
case json.RawMessage:
if len(cast) == 0 {
+ _, err := wr.Write(jsonrpc.Null)
+ if err != nil {
+ return err
+ }
} else {
_, err := wr.Write(cast)
if err != nil {
return err
}
}
- case *io.PipeReader:
- _, err := io.Copy(wr, cast)
- if err != nil {
- return err
- }
- cast.Close()
- case func(e io.Writer) error:
- err = cast(wr)
default:
err = jjson.Encode(w, cast)
}
--
GitLab