Fix a streaming bug

2019-06-20 12:44:51 +01:00 · 2019-06-20 12:44:51 +01:00 · 8d5d812e32
commit 8d5d812e32
parent 3f910038a3
1 changed files with 5 additions and 1 deletions
--- a/server/rpc_router.go
+++ b/server/rpc_router.go
@ -188,7 +188,11 @@ func (s *service) call(ctx context.Context, router *router, sending *sync.Mutex,
 		method:      req.msg.Method,
 		endpoint:    req.msg.Endpoint,
 		body:        req.msg.Body,
-		rawBody:     argv.Interface(),
+	}
+
+	// only set if not nil
+	if argv.IsValid() {
+		r.rawBody = argv.Interface()
 	}

 	if !mtype.stream {