set muxrpc header flag correctly
This commit is contained in:
parent
85ee99a1b2
commit
4d3b880acc
|
@ -51,6 +51,7 @@ func (h *Handler) attendants(ctx context.Context, req *muxrpc.Request, snk *muxr
|
||||||
h.state.AddEndpoint(*peer, req.Endpoint())
|
h.state.AddEndpoint(*peer, req.Endpoint())
|
||||||
|
|
||||||
// send the current state
|
// send the current state
|
||||||
|
snk.SetEncoding(muxrpc.TypeJSON)
|
||||||
err = json.NewEncoder(snk).Encode(AttendantsInitialState{
|
err = json.NewEncoder(snk).Encode(AttendantsInitialState{
|
||||||
Type: "state",
|
Type: "state",
|
||||||
IDs: h.state.ListAsRefs(),
|
IDs: h.state.ListAsRefs(),
|
||||||
|
|
Loading…
Reference in New Issue