Fixing return value and gofmt

client/options.go

@@ -75,11 +75,11 @@ func newOptions(options ...Option) Options {
 	opts := Options{
 		Codecs: make(map[string]codec.NewCodec),
 		CallOptions: CallOptions{
-			Backoff:          DefaultBackoff,
-			Retry:            DefaultRetry,
-			Retries:          DefaultRetries,
-			RequestTimeout:   DefaultRequestTimeout,
-			DialTimeout:      transport.DefaultDialTimeout,
+			Backoff:        DefaultBackoff,
+			Retry:          DefaultRetry,
+			Retries:        DefaultRetries,
+			RequestTimeout: DefaultRequestTimeout,
+			DialTimeout:    transport.DefaultDialTimeout,
 		},
 		PoolSize: DefaultPoolSize,
 		PoolTTL:  DefaultPoolTTL,

client/rpc_client.go

@@ -309,7 +309,6 @@ func (r *rpcClient) Call(ctx context.Context, request Request, response interfac
 				return err
 			}
 
-
 			gerr = err
 		}
 	}
@@ -421,7 +420,7 @@ func (r *rpcClient) Stream(ctx context.Context, request Request, opts ...CallOpt
 				return nil, rsp.err
 			}
 
-			grr = err
+			grr = rsp.err
 		}
 	}