fix conneciton hang in http server

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@memelabs/protobuf",
-  "version": "0.3.3",
+  "version": "0.3.4",
   "description": "",
   "license": "MIT",
   "repository": {

pkg/rpc/http_server.go

@@ -2,11 +2,13 @@ package rpc
 
 import (
 	"context"
-	"io/ioutil"
+	"encoding/binary"
+	"io"
 	"net/http"
 	"strconv"
 
 	pb "github.com/MemeLabs/protobuf/pkg/apis/rpc"
+	"github.com/MemeLabs/protobuf/pkg/bytereader"
 	"go.uber.org/zap"
 	"google.golang.org/protobuf/proto"
 )
@@ -24,24 +26,32 @@ type HTTPServer struct {
 }
 
 func (s *HTTPServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
-	b, err := ioutil.ReadAll(r.Body)
+	l, err := binary.ReadUvarint(bytereader.New(r.Body))
 	if err != nil {
 		httpServeError(http.StatusBadRequest, err, w)
 		return
 	}
 
+	b := make([]byte, l)
+	if _, err := io.ReadAtLeast(r.Body, b, int(l)); err != nil {
+		httpServeError(http.StatusBadRequest, err, w)
+		return
+	}
+
 	req := &pb.Call{}
 	if err := proto.Unmarshal(b, req); err != nil {
 		httpServeError(http.StatusBadRequest, err, w)
 		return
 	}
 
+	ctx, cancel := context.WithCancel(r.Context())
 	send := func(_ context.Context, res *pb.Call) error {
 		return httpServeProto(res, w)
 	}
-	call := NewCallIn(r.Context(), req, noopParentCallAccessor{}, send)
+	call := NewCallIn(ctx, req, noopParentCallAccessor{}, send)
 
-	s.ServiceDispatcher.Dispatch(call, func() {})
+	s.ServiceDispatcher.Dispatch(call, cancel)
+	<-ctx.Done()
 }
 
 func httpServeError(statusCode int, err error, w http.ResponseWriter) error {

pkg/rpc/server.go

@@ -96,6 +96,7 @@ func (h *ServiceDispatcher) call(call *CallIn, done func()) {
 	method, ok := h.methods[call.Method()]
 	if !ok {
 		call.returnError(fmt.Errorf("method not found: %s", call.Method()))
+		done()
 		return
 	}