hm

contrib/codecs/rdwr/client.go

@@ -152,9 +152,6 @@ func (c *Client) Notify(ctx context.Context, method string, params any) error {
 	return c.writeContext(ctx, fwd)
 }
 
-func (c *Client) SetHeader(key string, value string) {
-}
-
 func (c *Client) Close() error {
 	c.cn()
 	return nil

pkg/clientutil/idreply.go

@@ -76,13 +76,19 @@ func (i *IdReply) Resolve(id []byte, msg io.ReadCloser, err error) {
 	}
 
 	if err != nil {
-		ch <- msgOrError{
+		select {
+		case ch <- msgOrError{
 			err: err,
+		}:
+		default:
 		}
 		return
 	}
-	ch <- msgOrError{
+	select {
+	case ch <- msgOrError{
 		msg: msg,
+	}:
+	default:
 	}
 
 }