Merge 84ba8f6 into 77fad75

.gx/lastpubver

@@ -1 +1 @@
-1.0.12: QmWudFxN9c6GECgcVCTKRdPJPbBd5nABheBM8VBCh7LKN4
+1.0.13: Qmb8tTGhxUEcevnFMmuoRHkJb1GzmQ64umAorJvMvqYcPG

call.go

@@ -83,7 +83,7 @@ func (call *Call) watchContextWithStream(s inet.Stream) {
 			// Close() instead of Reset(). This lets the other
 			// write to the stream without printing errors to
 			// the console (graceful fail).
-			s.Close()
+			inet.FullClose(s)
 			call.doneWithError(call.ctx.Err())
 		}
 	}

client.go

@@ -7,6 +7,7 @@ import (
 	"sync"
 
 	host "github.com/libp2p/go-libp2p-host"
+	inet "github.com/libp2p/go-libp2p-net"
 	peer "github.com/libp2p/go-libp2p-peer"
 	protocol "github.com/libp2p/go-libp2p-protocol"
 )
@@ -266,9 +267,8 @@ func (c *Client) send(call *Call) {
 		call.doneWithError(err)
 		return
 	}
-	defer s.Close()
-	go call.watchContextWithStream(s)
 
+	go call.watchContextWithStream(s)
 	sWrap := wrapStream(s)
 
 	logger.Debugf("sending RPC %s.%s to %s", call.SvcID.Name,
@@ -289,18 +289,22 @@ func (c *Client) send(call *Call) {
 		s.Reset()
 		return
 	}
-	receiveResponse(sWrap, call)
+	err = receiveResponse(sWrap, call)
+	if err != nil {
+		s.Reset()
+		return
+	}
+	go inet.FullClose(s)
 }
 
 // receiveResponse reads a response to an RPC call
-func receiveResponse(s *streamWrap, call *Call) {
+func receiveResponse(s *streamWrap, call *Call) error {
 	logger.Debugf("waiting response for %s.%s to %s", call.SvcID.Name,
 		call.SvcID.Method, call.Dest)
 	var resp Response
 	if err := s.dec.Decode(&resp); err != nil {
 		call.doneWithError(err)
-		s.stream.Reset()
-		return
+		return err
 	}
 
 	defer call.done()
@@ -312,7 +316,7 @@ func receiveResponse(s *streamWrap, call *Call) {
 	// read
 	if err := s.dec.Decode(call.Reply); err != nil && err != io.EOF {
 		call.setError(err)
-		s.stream.Reset()
+		return err
 	}
-	return
+	return nil
 }

package.json

@@ -25,6 +25,6 @@
   "license": "MIT/BSD",
   "name": "go-libp2p-gorpc",
   "releaseCmd": "git commit -a -m \"gx publish $VERSION\"",
-  "version": "1.0.12"
+  "version": "1.0.13"
 }
 

server.go

@@ -124,15 +124,14 @@ func NewServer(h host.Host, p protocol.ID) *Server {
 	if h != nil {
 		h.SetStreamHandler(p, func(stream inet.Stream) {
 			sWrap := wrapStream(stream)
-			defer stream.Close()
+			defer inet.FullClose(stream)
 			err := s.handle(sWrap)
 			if err != nil {
 				logger.Error("error handling RPC:", err)
 				resp := &Response{ServiceID{}, err.Error()}
 				sendResponse(sWrap, resp, nil)
 			}
 		})
-
 	}
 	return s
 }