diff --git a/client/rpc_client.go b/client/rpc_client.go
index 3619540c..91d11a40 100644
--- a/client/rpc_client.go
+++ b/client/rpc_client.go
@@ -230,7 +230,7 @@ func (r *rpcClient) stream(ctx context.Context, node *registry.Node, req Request
 		response: rsp,
 		closed:   make(chan bool),
 		codec:    codec,
-		id: id,
+		id:       id,
 		// signal the end of stream,
 		eos: true,
 	}
diff --git a/client/rpc_stream.go b/client/rpc_stream.go
index 6db6b596..269e6299 100644
--- a/client/rpc_stream.go
+++ b/client/rpc_stream.go
@@ -133,7 +133,7 @@ func (r *rpcStream) Close() error {
 				Method:   r.request.Method(),
 				Endpoint: r.request.Endpoint(),
 				Type:     codec.Error,
-				Error: lastStreamResponseError,
+				Error:    lastStreamResponseError,
 			}, nil)
 		}
 
diff --git a/util/socket/socket.go b/util/socket/socket.go
index 77b0aac0..59bb538d 100644
--- a/util/socket/socket.go
+++ b/util/socket/socket.go
@@ -70,7 +70,7 @@ func (s *Socket) Send(m *transport.Message) error {
 	// make copy
 	msg := &transport.Message{
 		Header: make(map[string]string),
-		Body: make([]byte, len(m.Body)),
+		Body:   make([]byte, len(m.Body)),
 	}
 
 	// copy headers