Compare commits
5 Commits
63ae848043
...
v3.11.8
| Author | SHA1 | Date | |
|---|---|---|---|
| 069eaf4485 | |||
| fd670155aa | |||
| 0e3a199e16 | |||
| a665b69706 | |||
| 90b7b7ec1c |
@@ -29,6 +29,12 @@ var Handler = func(dst map[string]interface{}, fsys fs.FS) http.HandlerFunc {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if dst == nil {
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
_, _ = w.Write(buf)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
var src interface{}
|
var src interface{}
|
||||||
|
|
||||||
if err = c.Unmarshal(buf, src); err != nil {
|
if err = c.Unmarshal(buf, src); err != nil {
|
||||||
|
|||||||
@@ -111,7 +111,6 @@ func (s *Server) createSubHandler(sb *httpSubscriber, opts server.Options) broke
|
|||||||
}
|
}
|
||||||
|
|
||||||
hdr := metadata.Copy(msg.Header)
|
hdr := metadata.Copy(msg.Header)
|
||||||
delete(hdr, "Content-Type")
|
|
||||||
ctx := metadata.NewIncomingContext(context.Background(), hdr)
|
ctx := metadata.NewIncomingContext(context.Background(), hdr)
|
||||||
|
|
||||||
results := make(chan error, len(sb.handlers))
|
results := make(chan error, len(sb.handlers))
|
||||||
|
|||||||
Reference in New Issue
Block a user